awaitable Task based queue

by

I don’t know of a lock-free solution, but you can take a look at the new Dataflow library, part of the Async CTP. A simple BufferBlock<T> should suffice, e.g.:

BufferBlock<int> buffer = new BufferBlock<int>();

Production and consumption are most easily done via extension methods on the dataflow block types.

Production is as simple as:

buffer.Post(13);

and consumption is async-ready:

int item = await buffer.ReceiveAsync();

I do recommend you use Dataflow if possible; making such a buffer both efficient and correct is more difficult than it first appears.

More Related Contents:

  1. Is async HttpClient from .Net 4.5 a bad choice for intensive load applications?
  2. Using async / await with DataReader ? ( without middle buffers!)
  3. How to limit the amount of concurrent async I/O operations?
  4. Async/await vs BackgroundWorker
  5. WaitAll vs WhenAll
  6. HttpClient.GetAsync(…) never returns when using await/async
  7. Running multiple async tasks and waiting for them all to complete
  8. Calling async method synchronously
  9. What’s the difference between Task.Start/Wait and Async/Await?
  10. Entity Framework async operation takes ten times as long to complete
  11. Do you have to put Task.Run in a method to make it async?
  12. Why does this async action hang when I try and access the Result property of my Task?
  13. Task sequencing and re-entracy
  14. Calling async methods from a WCF service
  15. How to wait for async method to complete?
  16. Async call with await in HttpClient never returns
  17. Brief explanation of Async/Await in .Net 4.5
  18. Async and await – difference between console, Windows Forms and ASP.NET
  19. Why use async and return await, when you can return Task directly?
  20. async await return Task
  21. Executing tasks in parallel
  22. Proper way to start and fire-and-forget asynchronous calls?
  23. Use Task.Run() in synchronous method to avoid deadlock waiting on async method?
  24. A pattern for self-cancelling and restarting task
  25. A pattern to pause/resume an async task?
  26. Converting async/await to Task.ContinueWith
  27. How to Async Files.ReadAllLines and await for results?
  28. I thought await continued on the same thread as the caller, but it seems not to
  29. How do I create a custom SynchronizationContext so that all continuations can be processed by my own single-threaded event loop?
  30. Timeout pattern on task-based asynchronous method in C#

Leave a Comment