MonoGame.Extended/Source/MonoGame.Extended.Particles/ParticleModifierExecutionStrategy.cs

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(IEnumerable<IModifier> modifiers, float elapsedSeconds, ParticleBuffer.ParticleIterator iterator);

        internal class SerialModifierExecutionStrategy : ParticleModifierExecutionStrategy
        {
            internal override void ExecuteModifiers(IEnumerable<IModifier> modifiers, float elapsedSeconds,
                ParticleBuffer.ParticleIterator iterator)
            {
                foreach (var modifier in modifiers)
                    modifier.Update(elapsedSeconds, iterator.Reset());
            }
        }

        internal class ParallelModifierExecutionStrategy : ParticleModifierExecutionStrategy
        {
            internal override void ExecuteModifiers(IEnumerable<IModifier> modifiers, float elapsedSeconds,
                ParticleBuffer.ParticleIterator iterator)
            {
                TPL.Parallel.ForEach(modifiers, modifier => modifier.Update(elapsedSeconds, iterator.Reset()));
            }
        }

        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}'");
        }
    }
}