How to work threading with ConcurrentQueue

by

From my understanding of the problem, you are missing a few things.

The concurrent queue is a data structure designed to accept multiple threads reading and writing to the queue without you needing to explicitly lock the data structure. (All that jazz is taken care of behind the scenes, or the collection is implemented in such a way that it doesn’t need to take a lock.)

With that in mind, it looks like the pattern you are trying to use is the “Produce/Consumer”. First, you have some tasks producing work (and adding items to the queue). And second you have a second task Consuming things from the queue (and dequeing items).

So really you want two threads: one adding items and a second removing items. Because you are using a concurrent collection, you can have multiple threads adding items and multiple threads removing items. But obviously the more contention you have on the concurrent queue the quicker that will become the bottleneck.

More Related Contents:

  1. Creating a blocking Queue in .NET?
  2. The calling thread cannot access this object because a different thread owns it
  3. How do I update an ObservableCollection via a worker thread?
  4. Question about terminating a thread cleanly in .NET
  5. catch exception that is thrown in different thread
  6. What is the difference between await Task and Task.Result?
  7. Updating GUI (WPF) using a different thread
  8. ‘using’ statement vs ‘try finally’
  9. Thread.Sleep for less than 1 millisecond
  10. Can I serialize nested properties to my class in one operation with Json.net?
  11. When to use thread pool in C#? [closed]
  12. The current SynchronizationContext may not be used as a TaskScheduler
  13. STAThread and multithreading
  14. awaitable Task based queue
  15. Spawn Multiple Threads for work then wait until all finished
  16. “async Task then await Task” vs “Task then return task” [duplicate]
  17. c# working with Entity Framework in a multi threaded server
  18. How to terminate a thread in C#?
  19. Thread safe collections in .NET
  20. Is .GetAwaiter().GetResult(); safe for general use?
  21. Create multiple threads and wait for all of them to complete
  22. Is it safe to use a boolean flag to stop a thread from running in C#
  23. ConcurrentDictionary Pitfall – Are delegates factories from GetOrAdd and AddOrUpdate synchronized?
  24. Thread safety on readonly static field initialisation
  25. Synchronous implementation of interface that returns Task
  26. Populating a DataGridView with Text and ProgressBars
  27. How to properly parallelise job heavily relying on I/O
  28. Writing to file in a thread safe manner
  29. Using C# MethodInvoker.Invoke() for a GUI app… is this good?
  30. How can I enumerate all managed threads in C#?

Leave a Comment