Dispose_When_Tasks_Are_Queued_Then_All_Tasks_Are_Executed.cs

    [TestMethod]
    public virtual async Task Dispose_When_Tasks_Are_Queued_Then_All_Tasks_Are_Executed()
    {
      const int NUMBER_OF_TASKS = 1000;
      const int DELAY_TASK_CAN_CONTINUE_SIGNAL_S = 1;

      int numberOfTasksExecuted = 0;
      var waitForSignalCts = new CancellationTokenSource();

      var tasks = Enumerable.Range(0, NUMBER_OF_TASKS)
        .Select(taskIndex => TestTaskFactory.StartNew(() =>
                                                      {
                                                        waitForSignalCts.Token.WaitHandle.WaitOne();
                                                        return Interlocked.Increment(ref numberOfTasksExecuted);
                                                      })).ToArray();

      waitForSignalCts.CancelAfter(TimeSpan.FromSeconds(DELAY_TASK_CAN_CONTINUE_SIGNAL_S));
      Scheduler.Dispose();


      await Task.WhenAll(tasks);

      Assert.AreEqual(NUMBER_OF_TASKS, numberOfTasksExecuted);
    }