取消TPL数据流块的正确方法

Question

我正在使用TPL 块来执行可能被用户取消的操作： 我提出了两个选项，首先我取消整个块但不取消块内的操作，如下所示：

_downloadCts = new CancellationTokenSource();

var processBlockV1 = new TransformBlock<int, List<int>>(construct =>
{
    List<int> properties = GetPropertiesMethod(construct );
    var entities = properties
        .AsParallel()
        .Select(DoSometheningWithData)
        .ToList();
    return entities;
}, new ExecutionDataflowBlockOptions() { CancellationToken = _downloadCts.Token });

第二个我取消内部操作，但不是块本身：

var processBlockV2 = new TransformBlock<int, List<int>>(construct =>
{
    List<int> properties = GetPropertiesMethod(construct);
    var entities = properties
        .AsParallel().WithCancellation(_downloadCts.Token)
        .Select(DoSometheningWithData)
        .ToList();
    return entities;
});

据我了解，第一个选项将取消整个块，从而关闭整个管道。我的问题是它是否也会取消内部操作并处置所有资源（如果有的话（打开 StreamReaders 等）或者最好选择第二个选项，然后我自己可以确保所有内容都被取消和清理，然后我可以使用一些方法（铁路编程）将OperationCanceledException 浮出管道并在我想要的地方处理它？

Answer 1

这两个选项不等价。

1. 第一个选项 (CancellationToken = _downloadCts.Token) 将使processBlockV1 块丢弃当前在其缓冲区中的任何消息（其InputCount 属性将变为0），并停止接受新消息（调用其Post 方法将始终返回false)。它不会停止处理当前正在进行的消息。这些将被完全处理，但不会传播到任何链接的块。处理完这些消息后，块将以取消状态完成（其Completion.Status 属性将变为Canceled）。

2. 第二个选项（取消内部操作）对整个块没有影响。 Dataflow 块容忍从其处理函数中抛出的任何OperationCanceledException，并忽略有故障的项目并继续下一个项目。所以取消令牌后，所有发布的消息仍然会被处理，并且块将继续接受更多。它只是不会将任何东西传播到它的链接块，因为所有项目都会抛出 OperationCanceledException 并被忽略。在特定示例中，将为所有construct 消息调用GetPropertiesMethod 方法，因此将对块的完成施加延迟。区块的最终状态将是RanToCompletion。

重要的是要知道 Dataflow 块正在认真对待Completion 的概念。在报告完成之前，他们将等待他们知道的所有内容停止运行。如果您确实希望它们过早完成并留下仍在运行的任务，则必须使用wrapping your tasks with cancelable wrappers 之类的技巧。