using System;

using System.Collections.Concurrent;

using System.Threading;

using System.Threading.Tasks;

​

class ProducerConsumer

{

    private static BlockingCollection<int> _queue = new BlockingCollection<int>(5);

​

    static void Producer()

    {

        for (int i = 1; i <= 10; i++)

        {

            _queue.Add(i);

            Console.WriteLine($"Produced: {i}");

            Thread.Sleep(500);

        }

        _queue.CompleteAdding();

    }

​

    static void Consumer()

    {

        foreach (var item in _queue.GetConsumingEnumerable())

        {

            Console.WriteLine($"Consumed: {item}");

            Thread.Sleep(1000);

        }

    }

​

    public static void Main()

    {

        Task.Run(() => Producer());

        Task.Run(() => Consumer()).Wait();

    }

}

​