c# - 如果排队的项目数小于 BatchSize，如何在超时后自动调用 TriggerBatch？

Question

使用 Dataflow CTP(在 TPL 中)

如果当前排队或推迟的项目数量小于 BatchSize，超时后是否可以自动调用 BatchBlock.TriggerBatch？

更好的是:每次 block 收到新项目时，此超时应重置为 0。

Answer 1

是的，您可以通过将 block 链接在一起来相当优雅地完成此任务。在这种情况下，您需要设置一个 TransformBlock，将其链接到 BatchBlock“之前”。看起来像这样:

Timer triggerBatchTimer = new Timer(() => yourBatchBlock.TriggerBatch());

TransformBlock<T, T> timeoutTransformBlock = new TransformBlock<T, T>((value) =>
{
    triggerBatchTimer.Change(5000, Timeout.Infinite);

    return value; 
});

timeoutTransformBlock.LinkTo(yourBatchBlock);

yourBufferBlock.LinkTo(timeoutTransformBlock);