Как автоматически вызвать TriggerBatch после тайм-аута, если количество элементов в очереди меньше, чем BatchSize?

Question

Использование CTP потока данных (в TPL)

Существует ли способ автоматического вызова BatchBlock.TriggerBatch, если количество находящихся в очереди или отложенных элементов меньше, чем BatchSize, после истечения времени ожидания?

И лучше: этот тайм-аут должен сбрасываться на 0 каждый раз, когда блок получает новый элемент.

Answer 1

Да, вы можете сделать это довольно элегантно, связав вместе блоки.В этом случае вы хотите установить 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);