.NET中的异步编程下

 class Program
    {        static void Main(string[] args)
        {
            Task t = new Task((c) =>
                {                    int count = (int)c;                    for (int i = 0; i < count; i++)
                    {
                        Thread.Sleep(10);
                    }
                    Console.WriteLine("任务处理完成");
                }, 100);//no.1            t.Start(); 
            for (int i = 0; i < 100; i++)
            {
                Thread.Sleep(10);
            }
            Console.WriteLine("done");
        }
    }

 class Program
    {        static void Main(string[] args)
        {
            Task<int> t = new Task<int>((c) =>
                {                    int count = (int)c;                    int sum=0;                    for (int i = 0; i < count; i++)
                    {
                        Thread.Sleep(10);
                        sum+=i;
                    }
                    Console.WriteLine("任务处理完成");                    return sum;
                }, 100);
            t.Start();
            t.Wait();//no.1
            Console.WriteLine("任务执行的结果{0}", t.Result);//no.2
            for (int i = 0; i < 100; i++)
            {
                Thread.Sleep(10);
            }
            Console.WriteLine("done");
        }
}

class Program
    {        static void Main(string[] args)
        {
            CancellationTokenSource cts = new CancellationTokenSource();//no.1
            Task<int> t = new Task<int>((c) =>Sum(cts.Token ,(int)c), 100);//no.2            t.Start();
            cts.Cancel();//no.3如果任务还没完成，但是Task有可能完成啦
            for (int i = 0; i < 100; i++)
            {
                Thread.Sleep(10);
            }
            Console.WriteLine("done");
        }        static int Sum(CancellationToken ct, int count)
        {            int sum = 0;            for (int i = 0; i < count; i++)
            {                if (!ct.CanBeCanceled)
                {
                    Thread.Sleep(10);
                    sum += i;
                }                else
                {
                    Console.WriteLine("任务取消");                    //进行回滚操作
                    return -1;//退出任务                }
            }
            Console.WriteLine("任务处理完成");            return sum;
        }
    }

class Program
    {        static void Main(string[] args)
        {           
            Task<int> t = new Task<int>((c) =>Sum((int)c), 100);
            t.Start();
            t.ContinueWith(task => Console.WriteLine("任务完成的结果{0}", task.Result));//当任务执行完之后执行
            t.ContinueWith(task => Console.WriteLine(""), TaskContinuationOptions.OnlyOnFaulted);//当任务出现异常时才执行
            for (int i = 0; i < 200; i++)
            {
                Thread.Sleep(10);
            }
            Console.WriteLine("done");
        }        static int Sum( int count)
        {            int sum = 0;            for (int i = 0; i < count; i++)
            {       
                    Thread.Sleep(10);
                    sum += i;          
            }
            Console.WriteLine("任务处理完成");            return sum;
        }
    }

t.Start()之后调用第一个ContinueWith方法，该方法第一参数就是一个Action<Task>的委托类型，相当于是一个回调函数，在这里我也用lambda表达式，当任务完成就会启用一个新任务去执行这个回调函数。而第二个ContinueWith里面的回调方法却不会执行，因为我们的任务也就是Sum方法不会发生异常，不能满足TaskContinuationOptions.OnlyOnFaulted这个枚举条件。这种用法比委托的异步函数编程看起来要简单些。最关键的是ContinueWith的还有一个重载版本可以带一个TaskScheduler对象参数，该对象负责执行被调度的任务。FCL中提供两种任务调度器，均派生自TaskScheduler类型：线程池调度器，和同步上下文任务调用器。而在Winform窗体程序设计中TaskScheduler尤为有用，为什么这么说呢？因为在窗体程序中的控件都是有ui线程去创建，而我们所执行的后台任务使用线程都是线程池中的工作线程，所以当我们的任务完成之后需要反馈到Winform控件上，但是控件创建的线程和任务执行的线程不是同一个线程，如果在任务线程中去更新控件就会导致控件对象安全问题会出现异常。所以操作控件，就必须要使用ui线程去操作。因此在ContinueWith获取任务执行的结果的并反馈到控件的任务调度上不能使用线程池任务调用器，而要使用同步上下文任务调度器去调度，即采用ui这个线程去调用ContinueWith方法所绑定的回调用函数即Action<Task>类型的委托。下面将使用任务调度器来把异步执行的Sum计算结果反馈到Winform界面的TextBox控件中。

界面如下。

代码如下。

 public partial class Form1 : Form
    {        private readonly TaskScheduler contextTaskScheduler;//声明一个任务调度器
        public Form1()
        {
            InitializeComponent();
            contextTaskScheduler = TaskScheduler.FromCurrentSynchronizationContext();//no.1获得一个上下文任务调度器        } 
        private void button1_Click(object sender, EventArgs e)
        {
            Task<int> t = new Task<int>((n) => Sum((int)n),100);
            t.Start();
            t.ContinueWith(task =>this.textBox1 .Text =task.Result.ToString(),contextTaskScheduler);//当任务执行完之后执行
            t.ContinueWith(task=>MessageBox .Show ("任务出现异常"),CancellationToken.None ,TaskContinuationOptions.OnlyOnFaulted,contextTaskScheduler );//当任务出现异常时才执行        }        int Sum(int count)
        {            int sum = 0;            for (int i = 0; i < count; i++)
            {
                Thread.Sleep(10);
                sum += i;
            }
            Console.WriteLine("任务处理完成");            return sum;
        }
    }