.Net使用Cancellation Framework取消并行任务

.Net使用Cancellation Framework取消并行任务的攻略

在编写并行代码时，我们通常会遇到需要取消一组任务的情况，为此 .Net 提供了一套名为 “Cancellation Framework” 的机制来进行任务取消管理。本文将详细介绍 .Net 的 Cancellation Framework 的使用方法，同时提供两个示例以帮助理解。

Cancellation Framework概述

Cancellation Framework 是多任务取消机制在 .Net 中的实现。它提供了一个 CancellationToken 类型的对象，该对象在多个任务之间传递并控制任务的取消。Cancellation Token 可以与 .Net 提供的 Task 类型、PLINQ 查询、和异步方法搭配使用，以取消相关操作。

使用Cancellation Token取消Task

在使用 Task 进行多线程操作的情况下，我们可以通过 CancellationToken 来取消任务。

var cts = new CancellationTokenSource();
var token = cts.Token;

var task1 = Task.Factory.StartNew(() => {
  //执行任务 1
}, token);

var task2 = Task.Factory.StartNew(() => {
  //执行任务 2
}, token);

//执行取消操作
cts.Cancel();

这个示例中， CancellationTokenSource 和 CancellationToken 分别用于在任务中传递和控制取消。在创建任务时，传递 CancellationToken 以使任务可以感知到取消操作。当我们执行 cts.Cancel() 时，两个任务都将被取消。

使用Cancellation Token取消PLINQ查询

PLINQ（Parallel LINQ）是一个可以运行并行查询的库。Cancellation Token 可以用于在 PLINQ 查询中取消运行。

var cts = new CancellationTokenSource();
var token = cts.Token;

var query = from number in Enumerable.Range(1, 10000).AsParallel().WithCancellation(token)
            select number;

//执行取消操作
cts.Cancel();

在这个示例中，我们使用 CancellationToken 作为 PLINQ 查询的参数，并使用 AsParallel() 方法将查询转换为并行执行。在查询过程中，Cancellation Token 用于控制取消操作。当我们执行 cts.Cancel() 时，查询将被取消。

总结

Cancellation Framework 是 .Net 框架的重要组成部分，它提供了一种有效的机制来取消多任务执行。本文提供了两个示例，分别演示 CancellationToken 是如何在 Task 和 PLINQ 中使用的。

当我们需要编写可取消的操作时，Cancellation Framework 应该作为要考虑的解决方案之一。我们可以通过 CancellationToken 的适当使用，来实现多任务的取消控制，使我们的程序更加健壮和高效。