Example of Producer/Consumer using BlockingCollection

ProducerConsumer.cs

private readonly BlockingCollection<int>  _blockingQueue = new BlockingCollection<int>();

void Main()
{
	var producer = Producer();
	var consumer = Consumer();
	
	Task.WaitAll(producer, consumer);
	
	Console.WriteLine("Done");
}

private Task Producer()
{
	var data = Enumerable.Range(1, 5);
	
	return Task.Run(async () => 
	{
		foreach (var x in data)
		{
			await Task.Delay(TimeSpan.FromSeconds(1));
			Console.WriteLine(string.Format("Producer. Value = {0}. TimeStamp = {1}", x, DateTime.Now));
			_blockingQueue.Add(x);
		}

		_blockingQueue.CompleteAdding();
	});	
}

private Task Consumer()
{
	return Task.Run(() => 
	{
		foreach (var x in _blockingQueue.GetConsumingEnumerable())
		{
			Console.WriteLine(string.Format("Consumer: Value = {0}. TimeStamp = {1}", x, DateTime.Now));
		}
	});
}