CancellationToken Struct dot net, C#

CancellationToken Struct dot net

//Rextester.Program.Main is the entry point for your code. Don't change it.
//Compiler version 4.0.30319.17929 for Microsoft (R) .NET Framework 4.5

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text.RegularExpressions;

using System.Threading;
using System.Threading.Tasks;

namespace Rextester
{
    public class Program
    {
        public static void Main(string[] args)
        {
            // Define the cancellation token.
            CancellationTokenSource source = new CancellationTokenSource();
            CancellationToken token = source.Token;
            
            Random rnd = new Random();
            Object lockObj = new Object();      
            
            
            List<Task<int[]>> tasks = new List<Task<int[]>>();
            TaskFactory factory = new TaskFactory(token);
            
              for (int taskCtr = 0; taskCtr <= 2; taskCtr++) 
              {
                 int iteration = taskCtr + 1;
                 tasks.Add(factory.StartNew( () => {
                                       int value;
                                       int[] values = new int[10];
                                       for (int ctr = 1; ctr <= 10; ctr++) {
                                          lock (lockObj) {
                                             value = rnd.Next(0,101);
                                          }
                                          if (value == 0) { 
                                             source.Cancel();
                                             Console.WriteLine("Cancelling at task {0}", iteration);
                                             break;
                                          }   
                                          values[ctr-1] = value; 
                                       }
                                       return values;
                                    }, token));   
              }  try {
                     Task<double> fTask = factory.ContinueWhenAll(tasks.ToArray(), 
                                                      (results) => {
                                                         Console.WriteLine("Calculating overall mean...");
                                                         long sum = 0;
                                                         int n = 0; 
                                                         foreach (var t in results) {
                                                            foreach (var r in t.Result) {
                                                                  sum += r;
                                                                  n++;
                                                               }
                                                         }
                                                         return sum/(double) n;
                                                      } , token);
                     Console.WriteLine("The mean is {0}.", fTask.Result);
                  }   
                  catch (AggregateException ae) {
                     foreach (Exception e in ae.InnerExceptions) {
                        if (e is TaskCanceledException)
                           Console.WriteLine("Unable to compute mean: {0}", 
                                             ((TaskCanceledException) e).Message);
                        else
                           Console.WriteLine("Exception: " + e.GetType().Name);
                     }
                  }
                  finally {
                     source.Dispose();
                  }
         
        }
    }
}


run \| edit \| history \| help	0