Task Flusso dati, un blocco dati può essere modificato dallo stato di completamento?

Question

Vorrei sapere se è possibile modificare lo stato di completamento dei blocchi di dati?

Ad esempio, ho contrassegnato un blocco dati var block = new BufferBlock<int>(); completo di block.Complete(). Il blocco è collegato ad altri blocchi di dati. Vorrei sapere se riesco a eseguire lo block modificando lo stato di completamento allo stato originale! Completo.

Se ciò non è possibile, come posso eseguire più esecuzioni, incluso il completamento, senza dover a) scollegare tutti i blocchi, b) riattivare tutti i blocchi e c) ricollegare tutti i blocchi nuovamente?

Qualsiasi idea che possa facilitare l'esecuzione dei cicli di flusso dei dati, compreso il completamento di ciascun blocco lungo la catena senza dover ricreare l'intero framework?

Grazie

Answer 1

No, non è possibile “incompleta” un blocco di flusso di dati completata. Penso che quello che dovresti fare è aggiungere una bandiera a ciascun messaggio che dice se è l'ultimo messaggio in una corsa. Per rendere più semplice lavorare con esso, è possibile creare set di metodi di supporto come:

public static TransformBlock<Tuple<TInput, bool>, Tuple<TOutput, bool>> 
    CreateEnhancedTransformBlock<TInput, TOutput>(Func<TInput, TOutput> transform) 
{ 
    return new TransformBlock<Tuple<TInput, bool>, Tuple<TOutput, bool>>(
     tuple => Tuple.Create(transform(tuple.Item1), tuple.Item2)); 
} 

In questo modo, si entra in un delegato transform che si occupa solo con TInput e TOuput e la bandiera viene trasferito insieme ad ogni messaggio.