blob: 20a4d51cc70d5484ec753083804483516b923e39 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
using System;
using System.Collections.Generic;
using MonoGame.Extended.Particles.Modifiers;
namespace MonoGame.Extended.Particles
{
using TPL = System.Threading.Tasks;
public abstract class ParticleModifierExecutionStrategy
{
public static readonly ParticleModifierExecutionStrategy Serial = new SerialModifierExecutionStrategy();
public static readonly ParticleModifierExecutionStrategy Parallel = new ParallelModifierExecutionStrategy();
internal abstract void ExecuteModifiers(List<Modifier> modifiers, float elapsedSeconds, ParticleBuffer.ParticleIterator iterator);
internal class SerialModifierExecutionStrategy : ParticleModifierExecutionStrategy
{
internal override void ExecuteModifiers(List<Modifier> modifiers, float elapsedSeconds, ParticleBuffer.ParticleIterator iterator)
{
for (var i = 0; i < modifiers.Count; i++)
modifiers[i].Update(elapsedSeconds, iterator.Reset());
}
public override string ToString()
{
return nameof(Serial);
}
}
internal class ParallelModifierExecutionStrategy : ParticleModifierExecutionStrategy
{
internal override void ExecuteModifiers(List<Modifier> modifiers, float elapsedSeconds, ParticleBuffer.ParticleIterator iterator)
{
TPL.Parallel.ForEach(modifiers, modifier => modifier.Update(elapsedSeconds, iterator.Reset()));
}
public override string ToString()
{
return nameof(Parallel);
}
}
public static ParticleModifierExecutionStrategy Parse(string value)
{
if (string.Equals(nameof(Parallel), value, StringComparison.OrdinalIgnoreCase))
return Parallel;
if (string.Equals(nameof(Serial), value, StringComparison.OrdinalIgnoreCase))
return Serial;
throw new InvalidOperationException($"Unknown particle modifier execution strategy '{value}'");
}
}
}
|
