How to use IObservable/IObserver with ConcurrentQueue or ConcurrentStack
- by James Black
I realized that when I am trying to process items in a concurrent queue using multiple threads while multiple threads can be putting items into it, the ideal solution would be to use the Reactive Extensions with the Concurrent data structures.
My original question is at:
…