//            Copyright Keysight Technologies 2012-2019
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, you can obtain one at http://mozilla.org/MPL/2.0/.
using System.Linq;
using System.Threading;

namespace OpenTap.Plugins.BasicSteps
{
    [Display("²¢ÐÐ", Group: "Á÷³Ì¿ØÖÆ", Description: "ÔÚ×ÓÏß³ÌÖв¢ÐÐÔËÐÐ×ÓÐòÁÐ", Order: 0)]
    [AllowAnyChild]
    public class ParallelStep : TestStep
    {
        public override void Run()
        {
            TapThread.WithNewContext(Run2);
        }

        public void Run2()
        {
            var steps = EnabledChildSteps.ToArray();

            SemaphoreSlim sem = new SemaphoreSlim(0);
            var trd = TapThread.Current;

            Log.Info("Starting {0} child steps in separate threads.", steps.Length);
            foreach (var _step in steps)
            {
                var step = _step;
                TapThread.Start(() =>
                {
                    try
                    {
                        var run = RunChildStep(step);
                        while (run.SuggestedNextStep == step.Id)
                        {
                            run = RunChildStep(step);
                        }
                    }
                    catch
                    {
                        // no need to do anything. This thread will end now.
                        TapThread.WithNewContext(trd.Abort, null);
                    }
                    finally
                    {
                        sem.Release();
                    }
                });
            }

            for (int waits = 0; waits < steps.Length; waits++)
                sem.Wait();
        }
    }
}