Implementing Parallel Pipeline with BlockingCollection

This recipe will describe how to implement a specific scenario of a producer/consumer pattern, which is called Parallel Pipeline, using the standard BlockingCollection data structure.

Getting ready

To begin this recipe, you will need a running Visual Studio 2012. There are no other prerequisites. The source code for this recipe can be found at 7644_Code\Chapter10\Recipe2.

How to do it...

To understand how to implement Parallel Pipeline using BlockingCollection, perform the following steps:

1. Start Visual Studio 2012. Create a new C# Console Application project.
2. In the Program.cs file, add the following using directives:

   using System;
   using System.Collections.Concurrent;
   using System.Linq;
   using System.Threading;
   using System.Threading.Tasks;

3. Add the following code snippet below the Main method:

   private const int CollectionsNumber = 4;
   private const int Count = 10;
   
   class PipelineWorker<TInput, TOutput>
   {
     Func<TInput, TOutput> _processor...