Is there anything like asynchronous BlockingCollection?

by

There are four alternatives that I know of.

The first is Channels, which provides a threadsafe queue that supports asynchronous Read and Write operations. Channels are highly optimized and optionally support dropping some items if a threshold is reached.

The next is BufferBlock<T> from TPL Dataflow. If you only have a single consumer, you can use OutputAvailableAsync or ReceiveAsync, or just link it to an ActionBlock<T>. For more information, see my blog.

The last two are types that I created, available in my AsyncEx library.

AsyncCollection<T> is the async near-equivalent of BlockingCollection<T>, capable of wrapping a concurrent producer/consumer collection such as ConcurrentQueue<T> or ConcurrentBag<T>. You can use TakeAsync to asynchronously consume items from the collection. For more information, see my blog.

AsyncProducerConsumerQueue<T> is a more portable async-compatible producer/consumer queue. You can use DequeueAsync to asynchronously consume items from the queue. For more information, see my blog.

The last three of these alternatives allow synchronous and asynchronous puts and takes.

More Related Contents:

  1. Awaiting multiple Tasks with different results
  2. Running multiple async tasks and waiting for them all to complete
  3. Using async/await for multiple tasks
  4. StaTaskScheduler and STA thread message pumping
  5. Why should I prefer single ‘await Task.WhenAll’ over multiple awaits?
  6. Regarding usage of Task.Start() , Task.Run() and Task.Factory.StartNew()
  7. Task sequencing and re-entracy
  8. Synchronously waiting for an async operation, and why does Wait() freeze the program here
  9. How to use non-thread-safe async/await APIs and patterns with ASP.NET Web API?
  10. Enforce an async method to be called once
  11. Cancelling a pending task synchronously on the UI thread
  12. What is the use for Task.FromResult in C#
  13. Waiting for async/await inside a task
  14. Revisiting Task.ConfigureAwait(continueOnCapturedContext: false)
  15. ConfigureAwait pushes the continuation to a pool thread
  16. How can I prevent synchronous continuations on a Task?
  17. If my interface must return Task what is the best way to have a no-operation implementation?
  18. multiple awaits vs Task.WaitAll – equivalent?
  19. Executing tasks in parallel
  20. Difference between returning and awaiting a Task in an async method [duplicate]
  21. Use Task.Run() in synchronous method to avoid deadlock waiting on async method?
  22. Task.Factory.StartNew with async lambda and Task.WaitAll
  23. A pattern for self-cancelling and restarting task
  24. How to correctly write Parallel.For with async methods
  25. What is the correct way to cancel an async operation that doesn’t accept a CancellationToken?
  26. Converting async/await to Task.ContinueWith
  27. The lack of non-capturing Task.Yield forces me to use Task.Run, why follow that?
  28. How do I get a return value from Task.WaitAll() in a console app?
  29. Create a completed Task
  30. Wrapping ManualResetEvent as awaitable task

Leave a Comment