Come chiamare automaticamente TriggerBatch dopo un timeout se il numero di elementi in coda è inferiore al BatchSize?

Question

Utilizzando flusso di dati CTP (nel TPL)

C'è un modo per chiamare BatchBlock.TriggerBatch automaticamente se il numero di elementi attualmente in coda o posticipati è inferiore al BatchSize, dopo un timeout?

E meglio: questo timeout deve essere reimpostato su 0 ogni volta che il blocco riceve un nuovo elemento.

Answer 1

Sì, è possibile eseguire questo piuttosto elegantemente concatenando i blocchi. In questo caso si desidera configurare un TransformBlock che colleghi "prima" a BatchBlock. Sarebbe simile a questa:

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);