TPL Dataflow, guarantee completion only when ALL source data blocks completed

by

The issue is exactly what casperOne said in his answer. Once the first transform block completes, the processor block goes into “finishing mode”: it will process remaining items in its input queue, but it won’t accept any new items.

There is a simpler fix than splitting your processor block in two though: don’t set PropagateCompletion, but instead set completion of the processor block manually when both transform blocks complete:

Task.WhenAll(transformBlock1.Completion, transformBlock2.Completion)
    .ContinueWith(_ => processorBlock.Complete());

More Related Contents:

  1. TPL Dataflow, whats the functional difference between Post() and SendAsync()?
  2. How to limit the amount of concurrent async I/O operations?
  3. Best way in .NET to manage queue of tasks on a separate (single) thread
  4. For a TPL Dataflow: How do I get my hands on all the output produced by a TransformBlock while blocking until all inputs have been processed?
  5. ForEachAsync with Result
  6. BroadcastBlock with guaranteed delivery in TPL Dataflow
  7. TPL Dataflow exception in transform block with bounded capacity
  8. Batching on duration or threshold using TPL Dataflow
  9. How to mark a TPL dataflow cycle to complete?
  10. Collection was modified; enumeration operation may not execute
  11. Nesting await in Parallel.ForEach [duplicate]
  12. Best practice to call ConfigureAwait for all server-side code
  13. Running multiple async tasks and waiting for them all to complete
  14. Calling async method synchronously
  15. Parallel.ForEach and async-await [duplicate]
  16. What is a good pattern for using a Global Mutex in C#?
  17. Regarding usage of Task.Start() , Task.Run() and Task.Factory.StartNew()
  18. No ConcurrentList in .Net 4.0?
  19. Task sequencing and re-entracy
  20. List thread safety
  21. Set ApartmentState on a Task
  22. .NET Asynchronous stream read/write
  23. multiple awaits vs Task.WaitAll – equivalent?
  24. Process files concurrently and asynchronously
  25. Use Task.Run() in synchronous method to avoid deadlock waiting on async method?
  26. Simplest way to run three methods in parallel in C#
  27. Need to understand the usage of SemaphoreSlim
  28. The lack of non-capturing Task.Yield forces me to use Task.Run, why follow that?
  29. Task.Run with Parameter(s)?
  30. ConcurrentDictionary GetOrAdd async

Leave a Comment