TPL.Dataflow 消息处理超时？

Question

使用 .NET TPL DataFlow 块。 有没有办法让消息处理超时？

例如

假设我有一个BufferBlock<T>，是否可以将其链接到一次处理一条消息的另一个块 (MaxDegreeOfParallellism1) 并在处理运行时间过长时强制超时？ 或者甚至可以只使用 BufferBlock 吗？

我怀疑我可以以某种方式使用取消令牌和延迟，但不确定如何做到这一点。 另外，这样的超时会有多贵？是否会增加消息处理时间的开销？

Answer 1

BufferBlock<T> 的许多方法都接受CancellationToken，我相信这将是使操作超时的正确方法。例如：

var cts = new CancellationTokenSource(5000); // cancel in 5s 
// Alternatively: cts.CancelAfter(5000);

try 
{
    var output = await bufferBlock.ReceiveAsync(cts.Token);
}
catch (Exception ex)
{
    // check if ex is OperationCanceledException,
    // which could be wrapped with AggregateException 
}

IMO，评估其效率的唯一方法是运行一些分析测试。

[UPDATE] 基于 cmets，如果您希望使管道处理超时，您可以在构造 ActionBlock 对象并为其提供实例时执行此操作的ExecutionDataflowBlockOptions。此时，您可以提供DataflowBlockOptions.CancellationToken 并以与上述相同的方式使用它。此外，您可以将CancellationToken 作为DataflowLinkOptions 的一部分传递给LinkTo。

为管道提供CancellationToken 后，您可以跟踪ActionBlock.Completion/TransformBlock.Completion 的状态，即Task，因此您可以await 它并捕获取消异常，或使用ContinueWith（如果这是您在某种方式来判断消息的“处理”是否超时下的意思）。

免责声明：我自己没有尝试过，有兴趣知道它是否按预期工作。