Move source projects into source directory

2026-07-24 03:56:31 +00:00 · 2024-05-18 19:59:41 -04:00
parent 9c5f7cd3b4
commit a4d72eaf6c
423 changed files with 123 additions and 105 deletions
@@ -0,0 +1,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}'");
+        }
+    }
+}