[CLR via C#]26. 计算限制的异步操作

　　一、CLR线程池基础

前面说过，创建和销毁线程是一个比较昂贵的操作，太多的线程也会浪费内存资源。由于操作系统必须调度可运行的线程并执行上下文切换，所以太多的线程还有损于性能。为了改善这个情况，CLR使用了代码来管理它自己的线程池。可将线程池想像成可由你的应用程序使用的一个线程集合。每个进程都有一个线程池，它在各个应用程序域(AppDomain)是共享的.

//将方法排入队列以便执行。此方法在有线程池线程变得可用时执行。static Boolean QueueUserWorkItem(WaitCallback callBack);//将方法排入队列以便执行，并指定包含该方法所用数据的对象。此方法在有线程池线程变得可用时执行。static Boolean QueueUserWorkItem(WaitCallback callBack,Object state);

delegate void WaitCallback(Object state);

class PRogram    {        static void Main(string[] args)        {            Console.WriteLine("Main thread: queuing an asynchronous Operation");            ThreadPool.QueueUserWorkItem(ComputeBoundOp, 5);            Console.WriteLine("Main thread: Doing other work here...");            Thread.Sleep(10000);  // 模拟其它工作 (10 秒钟)            //Console.ReadLine();        }         // 这是一个回调方法，必须和WaitCallBack委托签名一致        private static void ComputeBoundOp(Object state)        {            // 这个方法通过线程池中线程执行            Console.WriteLine("In ComputeBoundOp: state={0}", state);            Thread.Sleep(1000);  // 模拟其它工作 (1 秒钟)             // 这个方法返回后，线程回到线程池，等待其他任务        }    } 

public sealed class ExecutionContext : IDisposable, ISerializable  {    [SecurityCritical]    //取消执行上下文在异步线程之间的流动    public static AsyncFlowControl SuppressFlow();    //恢复执行上下文在异步线程之间的流动    public static void RestoreFlow();    //指示当前是否取消了执行上下文的流动。    public static bool IsFlowSuppressed();     //不常用方法没有列出  }

class Program    {        static void Main(string[] args)        {            // 将一些数据放到Main线程的逻辑调用上下文中            CallContext.LogicalSetData("Name", "Jeffrey");             // 线程池能访问到逻辑调用上下文数据，加入到程序池队列中            ThreadPool.QueueUserWorkItem(               state => Console.WriteLine("Name={0}", CallContext.LogicalGetData("Name")));              // 现在阻止Main线程的执行上下文流动            ExecutionContext.SuppressFlow();             //再次访问逻辑调用上下文的数据            ThreadPool.QueueUserWorkItem(               state => Console.WriteLine("Name={0}", CallContext.LogicalGetData("Name")));             //恢复Main线程的执行上下文流动            ExecutionContext.RestoreFlow();             //再次访问逻辑调用上下文的数据            ThreadPool.QueueUserWorkItem(               state => Console.WriteLine("Name={0}", CallContext.LogicalGetData("Name")));            Console.Read();        }    }

  public class CancellationTokenSource : IDisposable    {         //构造函数         public CancellationTokenSource();         //获取是否已请求取消此 System.Threading.CancellationTokenSource         public bool IsCancellationRequested { get; }         //获取与此 System.Threading.CancellationTokenSource 关联的 System.Threading.CancellationToken         public CancellationToken Token;         //传达取消请求。         public void Cancel();         //传达对取消的请求，并指定是否应处理其余回调和可取消操作。         public void Cancel(bool throwOnFirstException);        ... }

 　　public struct CancellationToken  //一个值类型    {        //获取此标记是否能处于已取消状态，IsCancellationRequested 由非通过Task来调用(invoke)的一个操作调用(call)        public bool IsCancellationRequested { get; }        //如果已请求取消此标记，则引发 System.OperationCanceledException，由通过Task来调用的操作调用        public void ThrowIfCancellationRequested();        //获取在取消标记时处于有信号状态的 System.Threading.WaitHandle，取消时，WaitHandle会收到信号        public WaitHandle WaitHandle { get; }        //返回空 CancellationToken 值。        public static CancellationToken None        //注册一个将在取消此 System.Threading.CancellationToken 时调用的委托。省略了简单重载版本        public CancellationTokenRegistration Register(Action<object> callback, object state, bool useSynchronizationContext);         //省略了GetHashCode、Equals成员    }

　　class Program    {        static void Main(string[] args)        {            CancellationTokenSource cts = new CancellationTokenSource();             // 将CancellationToken和"要循环到的目标数"传入操作中            ThreadPool.QueueUserWorkItem(o => Count(cts.Token, 1000));             Console.WriteLine("Press <Enter> to cancel the operation.");            Console.ReadLine();            cts.Cancel();  // 如果Count方法已返回，Cancel没有任何效果            // Cancel立即返回，方法从这里继续运行             Console.ReadLine();        }         private static void Count(CancellationToken token, Int32 countTo)        {            for (Int32 count = 0; count < countTo; count++)            {                //判断是否接收到了取消任务的信号                if (token.IsCancellationRequested)                {                    Console.WriteLine("Count is cancelled");                    break; // 退出循环以停止操作                }                 Console.WriteLine(count);