using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.Threading.Tasks;

using System.Threading;

​

​

​

namespace TestProgramExecution

{

    //This is the model of a program step

    //A program is made of a list of steps in sequence

    public class Step

    {

        public int ID;

        public string Name;

        public TimeSpan ApplyTime;

    }

    //This is the controller of the step sequence

    //Expose a start and a stop method

    //Plus some relevants events

    public class ProgramController

    {

        public event EventHandler<StepChangeEventArgs> StepChangedEvent;

        public event EventHandler<EventArgs> ProgramAbortedEvent;

        public event EventHandler<EventArgs> ProgramFinishedEvent;

​

        public Stopwatch StepChronograph { get => _stepChronograph; }

​

​

        private List<Step> _executionSteps;

        private Stopwatch _stepChronograph = new Stopwatch();

        private int _stepIndexer;

        private Task _runningProgram;

        private CancellationToken ct;

        private CancellationTokenSource cs;

​

        public ProgramController(List<Step> executionsSteps)

        {

            _executionSteps = executionsSteps;

            _runningProgram = new Task(() => ProgramExecution(ct));

        }

​

        public void StartProgram()

        {

            if (_runningProgram.Status == TaskStatus.Running)

                return;

            cs = new CancellationTokenSource();

            ct = cs.Token;

            _runningProgram = new Task(() => ProgramExecution(ct));

            _runningProgram.Start();

​

        }

        public void StopProgram()

        {

            if (cs != null)

                cs.Cancel();

​

        }

​

        //This execute the step in the program

        private void ProgramExecution(CancellationToken cancellationRequest)

        {

            bool abort = false;

            foreach (var step in _executionSteps)

            {

                _stepChronograph.Stop();

                _stepChronograph.Reset();

                OnStepChanged(step);

                TimeSpan steptime = step.ApplyTime;

                _stepChronograph.Start();

                while (_stepChronograph.Elapsed < steptime)

                {

                    if (cancellationRequest.IsCancellationRequested)

                    {

                        abort = true;

                        break;

                    }

                }

                if (abort == true)

                {

                    OnProgramAborted();

                    _stepChronograph.Stop();

                    return;

                }

            }

            OnProgramFinished();

        }

​

        private void OnStepChanged(Step step)

        {

            if (StepChangedEvent != null)

                StepChangedEvent(this, new StepChangeEventArgs() { Step = step });

        }

        private void OnProgramFinished()

        {

            if (ProgramFinishedEvent != null)

                ProgramFinishedEvent(this, EventArgs.Empty);

        }

        private void OnProgramAborted()

        {

            if (ProgramAbortedEvent != null)

                ProgramAbortedEvent(this, EventArgs.Empty);

        }

​

    }

    //Event arguments

    public class StepChangeEventArgs : EventArgs

    {

        public Step Step;

    }

    //Main program console application, Main

    class Program

    {

        static void Main(string[] args)

        {

            //Steps are composed 

            //Add some steps

            List<Step> programSteps = new List<Step>();

            programSteps.Add(new Step()

            {

                ID = 1,

                Name = "step1",

                ApplyTime = TimeSpan.FromSeconds(5)

            });

            programSteps.Add(new Step()

            {

                ID = 2,

                Name = "step2",

                ApplyTime = TimeSpan.FromSeconds(2)

            });

​

            programSteps.Add(new Step()

            {

                ID = 3,

                Name = "step3",

                ApplyTime = TimeSpan.FromSeconds(3)

            });

​

​

            ProgramController controller = new ProgramController(programSteps);

            controller.StepChangedEvent += Controller_StepChangedEvent;

            controller.ProgramFinishedEvent += Controller_ProgramFinishedEvent;

            controller.ProgramAbortedEvent += Controller_ProgramAbortedEvent;

            Console.WriteLine("A=Start, S=Stop, Q=quit");

            while (true)

            {

​

                var key = new ConsoleKeyInfo('A', ConsoleKey.A, false, false, false);

​

                switch (key.Key)

                {

                    case ConsoleKey.A:

                        Console.WriteLine("Start Program");

                        controller.StartProgram();

                        break;

                    case ConsoleKey.S:

                        Console.WriteLine("AbortProgram");

                        controller.StopProgram();

                        break;

                    case ConsoleKey.Q:

                        controller.StopProgram();

                        return;

​

                }

            }

        }

​

        private static void Controller_ProgramAbortedEvent(object sender, EventArgs e)

        {

            Console.WriteLine("Program Aborted");

        }

​

        private static void Controller_ProgramFinishedEvent(object sender, EventArgs e)

        {

            Console.WriteLine("Program finished");

        }

​

        private static void Controller_StepChangedEvent(object sender, StepChangeEventArgs e)

        {

            Step step = e.Step;

            string stepdescriptor = string.Format("Current Step ID={0:d} Name={1} Time={2:c}", step.ID, step.Name, step.ApplyTime);

            Console.WriteLine(stepdescriptor);

        }

    }

}

​

​