Why Parallel.ForEach loop exits with OperationCancelledException, while using GetConsumableEnumerable? //outside the function static BlockingCollection<double> _collection = new BlockingColle...

I would like to await on the result of BlockingCollection<T>.Take() asynchronously, so I do not block the thread. Looking for anything like this: var item = await blockingCollection.TakeAsyn...

BlockingCollection contains only methods to add individual items. What if I want to add a collection? Should I just use foreach loop? Why BlockingCollection doesn't contain method to add a collecti...

I observed a strange behavior while experimenting with the Parallel.ForEach method and the BlockingCollection<T> class. Apparently calling the two lines below on a separate thread, is enough ...

I have multiple producers and a single consumer. However if there is something in the queue that is not yet consumed a producer should not queue it again. (unique no duplicates blocking collection ...

I have a concurrent BlockingCollection with repeated elements. How can modify it to add or get distinct elements?

I tried BlockingCollection and ConcurrentDictionary. It continues by adding BlockingCollection items as soon as the thread is completed, but ConcurrentDictionary is always adding thread order. Is t...

I'm working on project with following workflow : Background service consumme messages from Rabbitmq's queue Background service use background task queue like this and here to process task parallel...

I try to implement a ConcurrentDictionary by wrapping it in a BlockingCollection but did not seem to be successful. I understand that one variable declarations work with BlockingCollection such as ...

I've come up with some code to consume all wating items from a queue. Rather than processing the items 1 by 1, it makes sense to process all waiting items as a set. I've declared my queue like thi...

I have a recursive problem where the consumers do some work at each level of a tree, then need to recurse down the tree and perform that same work at the next level. I want to use ConcurrentBag/Blo...

I have a bunch of requests to process, and during the processing of those requests, more "sub-requests" can be generated and added to the same blocking collection. The consumers add sub-r...

I have one process generating work and a second process with a BlockingCollection<> that consumes that work. When I close my program, I need my consumer to stop consuming work, but I still ne...

I'm making use of the (frankly great) BlockingCollection<T> type for a heavily multithreaded, high-performance app. There's a lot of throughput through the collection and on the micro-level i...

I have been trying to get my head around the Blocking Collection and I came across Take() and TryTake() also Add() and TryAdd() I understand that if there are no items to take, Take() will wait ti...

I am running a thread that has a while(isRunning) { blockingCollection.Take() } First I am setting isRunning to false. Then I call thread.Interrupt which stops the blockingCollection from wa...

I have a server which communicates with 50 or more devices over TCP LAN. There is a Task.Run for each socket reading message loop. I buffer each message reach into a blocking queue, where each bl...

What scenarios is it better to use an ArrayBlockingQueue and when is it better to use a LinkedBlockingQueue? If LinkedBlockingQueue default capacity is equal to MAX Integer, is it really helpful t...

My program has 3 functions. Each function takes a list of Items and fill certain information. For example class Item { String sku,upc,competitorName; double price; } function F1 takes a List...

What is the difference between solution 1 and 2, _taskQ is BlockingCollection and I am trying to implement a Producer-Consumer scenario. The BlockingCollection uses the default ConcurrentQueue for ...

I have a quantifiable & repeatable problem using the Task Parallel Library, BlockingCollection<T>, ConcurrentQueue<T> & GetConsumingEnumerable while trying to create a simple pi...

I have a Download Queue implemented with BlockingCollection<>. Now I want to prioritize some Download once in a while. I thought it might be great to move some elements 'up' the Collection, l...

I wrote the following method to batch process a huge CSV file. The idea is to read a chunk of lines from the file into memory, then partition these chunk of lines into batches of fixed size. Once w...

I am adding Background Tasks to a Blocking Collection (added in the Background). I am waiting with Task.WhenAll on a Enumerable returned by GetConsumingEnumerable. My question is: Is the overload...

I'm a little bit confused about BlockingConnection and AsyncoreConnection. I want to send some messages to the RabbitMQ queue from a Django app. Is it ok to do that using a global BlockingConnectio...