【.NET Core】Task应用详解

曾经终败给现在 2024-02-17 09:57 19阅读 0赞

## 【.NET Core】Task应用详解 ##

#### 文章目录 ####

*  【.NET Core】Task应用详解
 *   *  一、概述
     *  二、Task用法应用
     *   *  2.1 通过New实例化Task
         *  2.2 通过Factory中StartNew方法
         *  2.3 通过Run方法
     *  三、让Task任务按顺序执行
     *  四、通过异步Run方法异步执行顺序Task
     *  五、创建带有返回值的Task<TResult>
     *  六、Task常用的属性与方法
     *  七、Task总结
     *  七、参考资料

### 一、概述 ###

`Task`（任务）是一个类似于`Thead`（线程）或`ThreadPool`（线程池）概念是一个异步执行的工具类。它是一个更轻的类线程工具。`Task`提供简化编写并发和异步代码的工具类。它包含的类型为`Task`和`Task<TResult>`。`TaskFactory`类提供用于创建和启动Task任务的静态方法。`TaskScheduler`类提供默认线程调度基础结构。

`Task`表示不返回值且通常异步执行的单个操作。`Task`对象是.NET Framework4中首次引入的基于任务的异步模式的核心组件之一。由于对象执行Task的工作通常在线程池线程上异步执行，而不是在main应用程序线程上同步执行，因此可以使用Statu属性以及IsCanceled、IsCompleted和IsFaulted属性来确定任务的状态。

### 二、Task用法应用 ###

Task基本使用可以通过New实例化一个Task的应用，也使用通过StartNew来使用Task，还有一种是通过Run使用Task。下面实例通过代码演示三种Task基本的应用。

#### 2.1 通过New实例化Task ####

Task task1=new Task(()=>{
        Thread.Sleep(1000);
        Debug.WriteLine("执行第一个Task任务.") 
    });
    Debug.WriteLine($"Task ID"+task1.id)

输出结果：

线程 0x6704 已退出，返回值为 0 (0x0)。
    第一个任务ID13
    执行第一个Task任务

#### 2.2 通过Factory中StartNew方法 ####

Task task2=new Task(()=>{
        Thread.Sleep(1500);
        Debug.WriteLine("执行第二个Task任务.") 
    });
    Debug.WriteLine($"Task2 ID"+task2.id);

#### 2.3 通过Run方法 ####

Task task3=new Task(()=>{
       Thread.Sleep(2000);
       Debug.WriteLine("执行第三个Task任务.");
    })
    Debug.WriteLine($"Task3 ID"+task3.id);

上面三种方法都可以创建一个`Task`应用。

> 类Task提供的异常三种创建任务和执行任务的方法。出于性能原因，Task.Run或TaskFactory.StartNew方法是创建和计划计算任务的首选机制，但对于必须分离创建和计划的方案，才考虑使用Task.Start方法计划任务以供以后执行。

### 三、让Task任务按顺序执行 ###

Task task1 = new Task(() => { 
        Thread.Sleep(1000);
        Debug.WriteLine("执行第一个Task任务");
    });
    Task task2 = new Task(() => {
        Thread.Sleep(5000);
        Debug.WriteLine("执行第二个Task任务");
    });
    Task task3 = new Task(() => {
         Thread.Sleep(2000);
         Debug.WriteLine("执行第三个Task任务");
    });
    Task task4 = new Task(() => {
         Thread.Sleep(1000);
         Debug.WriteLine("执行第四个Task任务");
    });
    
    IList<Task> tasks= new List<Task>();
    tasks.Add(task1);
    tasks.Add(task2);
    tasks.Add(task3);
    tasks.Add(task4);
    foreach (var task in tasks) {
        task.Start();
        task.Wait();
    }

如果想要Task按顺序执行，需要给Task加上Wait方法，然后让其阻塞等待完成后在执行下一个Task任务。

### 四、通过异步Run方法异步执行顺序Task ###

public async void RunTask() 
     {
         await Task.Run(async () =>{
             await Task.Delay(1000);
             Debug.WriteLine("第1个线程执行");
         });
         await Task.Run(async () =>{
              await Task.Delay(8000);
              Debug.WriteLine("第2个线程执行");
          });
         await Task.Run(async () =>{
              await Task.Delay(2000);
              Debug.WriteLine("第3个线程执行");
         });
         await Task.Run(async () =>{
              await Task.Delay(3000);
              Debug.WriteLine("第4个线程执行");
         });
    }

通过异步await 和async通过 Task.Run创建按次序的`Task`任务。

### 五、创建带有返回值的Task ###

Task和Task暴露静态的Factory属性，该属性返回一个默认的TaskFactory实例，以便调用Task.Factory.StartNew()方法。Task和Taste有一个属性Result属性，该属性包含了运算的结果。任务是异步运行的，可能以任意时序执行完。若Result属性在运行结束前被访问，这个属性会阻塞调用线程到该值可访问。

public async void RunTask() 
    {
          Task<Double>[] taskArray = { 
              Task<Double>.Factory.StartNew(() => DoComputation(10.0)),
              Task<Double>.Factory.StartNew(() => DoComputation(100.0)),
              Task<Double>.Factory.StartNew(() => DoComputation(1000.0)) 
          };
          foreach (var task in taskArray)
          {
               double result = task.Result;
               Debug.WriteLine(result);
          }
    }

### 六、Task常用的属性与方法 ###

**6.1 AsyncStates属性**

获取在创建Task时提供的状态对象，如果未提供，则为null。

**6.2 CompletedTask属性**

获取一个已成功的任务

**6.2 CurrentId属性**

返回当前正在执行Task的ID

**6.3 Factory属性**

提供对用于创建和配置Task和Task实例的工厂方法的访问

**6.4 Id属性**

获取此Task实例的ID

**6.5 IsCanceled属性**

获取此Task实例是否由于被取消的原因而完成执行

**6.6 IsCompleted属性**

获取一个值，它表示是否已完成任务

**6.7 IsCompletedSuccessfully属性**

了解任务是否运行到完成

**6.7 IsFaulted属性**

获取Task是否由于未经处理异常的原因而完成

**6.8 Status属性**

表示Task的生命周期中的当前阶段

*  0 = Created 该任务已初始化，但尚未被计划
 *  1 = WaitingForActivation 该任务正在等待 .NET 基础结构在内部将其激活并进行计划。
 *  2 = WaitingToRun 该任务已被计划执行，但尚未开始执行
 *  3 = Running 该任务正在运行，但尚未完成
 *  4 = WaitingForChildrenToComplete 该任务已完成执行，正在隐式等待附加的子任务完成
 *  5 = RanToCompletion 已成功完成执行的任务
 *  6 = Canceled 该任务已通过对其自身的 CancellationToken 引发 OperationCanceledException 对取消进行了确认，此时该标记处于已发送信号状态；或者在该任务开始执行之前，已向该任务的 CancellationToken 发出了信号
 *  7 = Faulted 由于未处理异常的原因而完成的任务

**6.9 ConfigureAwait(Boolean) 方法**

配置用于等待此Task的awaiter

**6.10 ContinueWith(Action<Task,Object>,Object,TaskScheduler) 方法**

创建一个在目标Task完成时接收调用方提供的状态信息和取消标记并执行的延续任务。延续任务根据一组指定的条件执行，并使用指定的计划程序。

**6.11 Delay(TimeSpan，CancellationToken) 方法**

创建一个在指定的毫秒数后完成的可取消任务或创建一个指定的时间间隔后完成的可取消的任务。

**6.12 Run(Action，CancellationToken) 方法**

将在线程池上运行的指定工作排队，并返回代表该工作的 `Task`对象。 可使用取消标记来取消工作（如果尚未启动）。

**6.13 Start(TaskScheduler) 方法**

启动Task, 并将它安排到当前的TaskScheduler中执行

**6.14 Wait(Task\[\],CancellationToken) 方法**

等待提供的所有Task对象在指定的毫秒数内完成执行，或等到取消等待