Hands-On Parallel Programming with C# 8 and .NET Core 3

Using queues to solve a producer-consumer problem

In this example, we will create a producer and consumer scenario using queues that are defined in the System.Collections namespace. There will be multiple tasks that will attempt to read or write to a queue and we need to ensure that the reads and writes are atomic:

1. Let's first create queue and populate it with some data:

Queue<int> queue = new Queue<int>();for (int i = 0; i < 500; i++) {    queue.Enqueue(i);}

2. Declare a variable that will hold the final result:

int sum = 0;

3. Next, we will create a parallel loop that will read the item from the queue using multiple tasks and add the sum in a thread-safe manner to the sum variable declared previously:

Parallel.For(0, 500, (i) =>{ int localSum ...