C#基础教程（七）Task

绝地灬酷狼 2022-11-04 13:25 152阅读 0赞

线程：  
Thread，由CLR提供，可以提供细粒度的线程控制，但是在返回值、多个线程并行/串行时候显得功能不足，需要进一步封装才行，而且线程的开启、停止都需要时间开销，乱用的话还造成浪费。  
线程池：  
ThreadPool，由CLR提供，提供粗粒度的线程控制，主要用来执行短时间内执行的代码片段，一个进程有一个线程池，由CLR统一调度。它对线程的控制力较少，而且在返回值、多个线程并行/串行时候显也是功能不足。

** 多线程的例子，但在实际开发中使用的线程往往是大量的和更为复杂的，这时，每次都创建线程、启动线程。从性能上来讲，这样做并不理想（因为每使用一个线程就要创建一个，需要占用系统开销）；从操作上来讲，每次都要启动，比较麻烦。为此引入的线程池的概念。**

**益处：**

1.减少在创建和销毁线程上所花的时间以及系统资源的开销   
       2.如不使用线程池，有可能造成系统创建大量线程而导致消耗完系统内存以及”过度切换”。

**在什么情况下使用线程池？ **  
  
       1.单个任务处理的时间比较短   
       2.需要处理的任务的数量大

线程池最多管理线程数量=“处理器数 \* 250”。也就是说，如果您的机器为2个2核CPU，那么CLR线程池的容量默认上限便是1000

通过线程池创建的线程默认为后台线程，优先级默认为Normal。

任务：  
Task，对ThreadPool和Thread的包装，可以根据任务时间长短选择使用线程池还是新的线程，通过进一步扩展，增加了返回值、多个线程并行/串行等功能。它的核心是一个调度器，默认是ThreadPoolTaskScheduler。

1.任务是架构在线程之上的，也就是说任务最终还是要抛给线程去执行。

2.任务跟线程不是一对一的关系，比如开10个任务并不是说会开10个线程，这一点任务有点类似线程池，但是任务相比线程池有很小的开销和精确的控制。

![三者关系][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmd3ZW54dWUxOTg5_size_16_color_FFFFFF_t_70] Thread、ThreadPool和Task三者关系

在.net4.5之后MS就推出了Task多线程，作为之前一直使用Thread和ThreadPool的开发者来说，Task显然更容易管理线程，虽然也够用，但还是要保持与时俱进嘛~Task使用的是线程池，耗时操作不易用在线程池中操作。

Task task=new Task(()=>{xxx});task.Start();
    //这是一种Task多线程构造方法，不会阻塞，是Action委托类型，用不到返回值
    
    Task<type> task=Task<type>.Run(()=>{带返回值func});
    timerTxt.Text= task.Result.toString();
    //如果下面程序用到Result这个返回参数，就会等这个线程结束再进行其它操作，会造成界面卡死，与WaitAll和WaitAny效果一致
    
    Task task=Task.Run(()=>{不带返回值func});
    //不会造成界面卡死，因为独立线程无返回值

用到Task，肯定会涉及WaitAll()，WaitAny()，WhenAll()，WhenAny()。

WaitAll();//阻塞线程，等所有task都结束才进行下面操作
    WaitAny();//阻塞线程，某一task先结束即可进行下面操作
    WhenAll();//不阻塞线程，等待所有操作，一般跟ContinueWith()搭配用
    WhenAny();//不阻塞线程，某一线程结束即可进行下面操作
    
    Task.WhenAll(task).ContinueWith(func);//void或返回值都行
    Task.Factory.ContinueWhenAll(tasks,func)//param1-Task[],param2-Action/Func
    // ContinueWith 就是任务完成后执行的方法体，不会卡死线程

用到Task，再看看 Task.Factory.StartNew，这是一个.net4.0之后推出的多线程，用的是Task线程池封装，Task.Factory.StartNew用法就是给一个Action委托就行，很easy。

下面看看Task的具体用法示例：

static void Main(string[] args)
    {
        CancellationTokenSource cts = new CancellationTokenSource();
        Task task1 = new Task(() =>
        {
            try
            {
                for (int i = 0; i < 10111000; i++)
                {
                    Console.WriteLine(i.ToString());
                    if (cts.Token.IsCancellationRequested)
                        //break; //可以跳出循环起到"结束线程",不一定try{}catch{}
                        //throw new OperationCanceledException(cts.Token);
                        //异常形式来"结束线程",一定要捕捉。不用IsCancellationRequested判断直接写也可以，这个函数定义是:如果已请求取消此标记，则引发 System.OperationCanceledException。有一定条件
                        cts.Token.ThrowIfCancellationRequested();
                 }
            }
            catch (Exception ex)
            {
                Console.WriteLine("立即终止");
            }
                   
        },cts.Token);        
        task1.Start();
        Thread.Sleep(1000);
        cts.Cancel();
        Console.ReadKey();
    }
    //无论如何形式，并不是像Thread.abort()这种粗暴的方式真正意义上结束线程，这里只是用逻辑处理来跳出线程。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmd3ZW54dWUxOTg5_size_16_color_FFFFFF_t_70]: /images/20221023/aa45c48b22ce455194a047bd0ab931f3.png