基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：78630559

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

Task使用实例

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace TaskTest
{
    class Program
    {
        static void Main(string[] args)
        {
            #region Task的状态
            //var task1 = new Task(() =>
            //{
            //    Console.WriteLine("Begin");
            //    System.Threading.Thread.Sleep(2000);
            //    Console.WriteLine("Finish");
            //});
            //Console.WriteLine("Before start:"   task1.Status);
            //task1.Start();
            //Console.WriteLine("After start:"   task1.Status);
            //task1.Wait();
            //Console.WriteLine("After Finish:"   task1.Status);

            //Console.Read();
            #endregion

            #region 多任务执行
            //var task1 = new Task(() =>
            //{
            //    Console.WriteLine("Task 1 Begin");
            //    System.Threading.Thread.Sleep(2000);
            //    Console.WriteLine("Task 1 Finish");
            //});
            //var task2 = new Task(() =>
            //{
            //    Console.WriteLine("Task 2 Begin");
            //    System.Threading.Thread.Sleep(3000);
            //    Console.WriteLine("Task 2 Finish");
            //});

            //task1.Start();
            //task2.Start();
            //Task.WaitAll(task1, task2);
            //Console.WriteLine("All task finished!");

            //Console.Read();
            #endregion

            #region 等待任一个任务执行完毕
            //var task1 = new Task(() =>
            //{
            //    Console.WriteLine("Task 1 Begin");
            //    System.Threading.Thread.Sleep(2000);
            //    Console.WriteLine("Task 1 Finish");
            //});
            //var task2 = new Task(() =>
            //{
            //    Console.WriteLine("Task 2 Begin");
            //    System.Threading.Thread.Sleep(3000);
            //    Console.WriteLine("Task 2 Finish");
            //});

            //task1.Start();
            //task2.Start();
            //Task.WaitAny(task1, task2);
            //Console.WriteLine("All task finished!");

            //Console.Read();
            #endregion

            #region 一个Task执行完成之后执行另一个Task
            //var task1 = new Task(() =>
            //{
            //    Console.WriteLine("Task 1 Begin");
            //    System.Threading.Thread.Sleep(2000);
            //    Console.WriteLine("Task 1 Finish");
            //});
            //var task2 = new Task(() =>
            //{
            //    Console.WriteLine("Task 2 Begin");
            //    System.Threading.Thread.Sleep(3000);
            //    Console.WriteLine("Task 2 Finish");
            //});

            //task1.Start();
            //task2.Start();
            //var result = task1.ContinueWith<string>(task =>
            //{
            //    Console.WriteLine("task1 finished!");
            //    return "This is task result!";
            //});

            //Console.WriteLine(result.Result.ToString());
            //Console.Read();
            #endregion
            #region TaskContinuationOptions使用
            //Task<Int32> t = new Task<Int32>(i => Sum((Int32)i), 10000);

            //t.Start();

            //t.ContinueWith(task => Console.WriteLine("The sum is:{0}", task.Result),
            //    TaskContinuationOptions.OnlyOnRanToCompletion);

            //t.ContinueWith(task => Console.WriteLine("Sum throw:"   task.Exception),
            //    TaskContinuationOptions.OnlyOnFaulted);

            //t.ContinueWith(task => Console.WriteLine("Sum was cancel:"   task.IsCanceled),
            //    TaskContinuationOptions.OnlyOnCanceled);
            //try
            //{
            //    t.Wait();  // 测试用
            //}
            //catch (AggregateException)
            //{
            //    Console.WriteLine("出错");
            //}
            //Console.Read();
            #endregion


            Task<Int32[]> parent = new Task<Int32[]>(() => {
                var results = new Int32[3];
                //
                new Task(() => results[0] = Sum(10000), TaskCreationOptions.AttachedToParent).Start();
                new Task(() => results[1] = Sum(20000), TaskCreationOptions.AttachedToParent).Start();
                new Task(() => results[2] = Sum(30000), TaskCreationOptions.AttachedToParent).Start();
                return results;
            });

            var cwt = parent.ContinueWith(parentTask => Array.ForEach(parentTask.Result, Console.WriteLine));


            parent.Start();
            cwt.Wait();
            Console.Read();
        }

        private static Int32 Sum(Int32 i)
        {
            Int32 sum = 0;
            for (; i > 0; i--)
            {
                checked { sum  = i; }
            }
            return sum;
        }
        
    }
}