ronnieoverby · March 20, 2019 17:11
diff --git a/BlockingCollectionExample.cs b/BlockingCollectionExample.cs
 var queue = new BlockingCollection<object>();

 // ... meanwhile some other thread is adding to the queue
 Task.Run(() => 
 {
 	for (int i = 0; i < 10; i++)
 		queue.Add(i);
 	
 	queue.CompleteAdding();
 });

 foreach (var item in queue.GetConsumingEnumerable())
 {
 	// do something with item
 	item.Dump();
 }
	var queue = new BlockingCollection<object>();

	// ... meanwhile some other thread is adding to the queue
	Task.Run(() =>
	{
	for (int i = 0; i < 10; i++)
	queue.Add(i);

	queue.CompleteAdding();
	});

	foreach (var item in queue.GetConsumingEnumerable())
	{
	// do something with item
	item.Dump();
	}