C# .Net并行(多核)编程 3 - Task的基本用法(取消Task的执行)

转自:http://ggicci.blog.163.com/blog/static/210364096201272034821778/

Title :

• Pro .NET 4 Parallel Programming in C# (Adam Freeman) Task的基本用法
• Task 的取消

---

 

Steps :

 

 

Quote :

You must also throw an instance of System.Threading.OperationCanceledException in your task body; this is how you acknowledge the cancellation, and if you forget, the status of your task will not be set correctly. [ From “Pro .Net 4 Parallel Programming in C#”]

你必须在你的Task的执行体里面抛出一个System.Threading.OperationCanceledException异常。具体有两种形式 :

1. while(true) {
       if(token.IsCancellationRequested) {
           throw new OperationCanceledException(token);
       } else {
           //do your work
       }
   }

    

2. while(true) {
       token.ThrowIfCancellationRequested();
       //do your work
   }

Simple Sample :

using System;
using System.Threading;
using System.Threading.Tasks;

namespace Parallel_TaskProgramming
{
    class Program
    {
        public static void Main(string[] args)
        {
            //step 1: create a instance of System.Threading.CancellationTokenSource
            CancellationTokenSource tokenSource = new CancellationTokenSource();
            //step 2: call the CancellationTokenSource.Token property to get a System.Threading.CancellationToken
            CancellationToken token = tokenSource.Token;

            //step 3: create a new Task or Task<T>
            Task task = new Task(() => {
                int i = 0;
                while (true)
                {
                    token.ThrowIfCancellationRequested();
                    Console.WriteLine(i++);
                }
            }, token);

            //step 4: start the task and then you can call CancellationTokenSource.Cancel() to cancel the task
            task.Start();
            //主线程睡眠 5 ms
            Thread.Sleep(5);
            tokenSource.Cancel();

            Console.WriteLine("Press enter to finish.");
            Console.ReadLine();
        }
    }
}

Result : 结果是不确定的，5 ms 能打印多少次数字取决于运行时 CPU 的忙碌程度

0
1
2
3
4
5
6
7
8
9
10
11
12
Press enter to finish.

---

Register : Monitoring Cancellation with a Delegate

CancellationToken 的 Register 方法可以为 token 登记一个 Action 或 Action<Object> 委托(代理)的实例。当 Task 被取消执行后，这个委托会被执行。

在上面 Simple Sample 的代码中的 task.Start() 前加上如下代码：

token.Register(() =>
{
    Console.WriteLine("Task was canceled and then I'm invoked.");
});

Result :

0
1
2
3
4
Task was canceled and then I'm invoked.
Press enter to finish.

---

WaitHandle : Monitoring Cancellation with a Wait Handle

CancellationToken 有个 WaitHandle 属性，这个属性是一个 WaitHandle 类的对象，WaitHandle 类的 WaitOne 方法的作用是：阻塞当前线程，直到当前的 WaitHandle 接收到一个信号。

Sample :

public static void Main(string[] args)
{
    CancellationTokenSource tokenSource = new CancellationTokenSource();
    CancellationToken token = tokenSource.Token;

    Task task = new Task(() =>
    {
        Console.WriteLine("Task running...");
        token.WaitHandle.WaitOne();
        Console.WriteLine("Hello");
    }, token);

    Console.WriteLine("Press enter to cancel the task.");
    task.Start();

    //按空格键取消任务
    Console.ReadLine();
    tokenSource.Cancel();

    Console.WriteLine("Press enter to finish.");
    Console.ReadLine();
}

Result :

Press enter to cancel the task.
Task running...

Hello
Press enter to finish.

---

Canceling Several Tasks : 取消多个任务

很简单，只需要在创建任务的时候用同一个 CancallationToken 的实例就可以了。