Repository navigation
possibility to take() from several queues #1
Description
could you, please, show a short example of consuming from multiple BlockingCollection instances
similar to BlockingCollection.TakeFromAny Method
thank you
could you, please, show a short example of consuming from multiple BlockingCollection instances
similar to BlockingCollection.TakeFromAny Method
thank you
Activity
gm127 commentedon Jan 29, 2019
@alex-bermishev The .net core implementation of TryTakeFromAnyCore provides an example of how to implement the fast path (i.e. non-blocking). The slow path (i.e. blocking) will be a bit more work. My initial thoughts would be to create a BlockingCollectionAggregator class. The constructor would take as input the data source collections you want to take from. Plus it would have its own internal collection. The aggregator would spin up tasks to wait on each data source collection. When data arrives from any it would get enqueued to its internal collection. The internal collection is what would feed BlockingCollectionAggregator's Take method. The Take method would include the fast path mentioned above. Additional housekeeping would be needed to manage the tasks.