using System;

using System.Threading;

using System.Threading.Tasks.Dataflow;

​

public static class Program

{

    static void Main(string[] args)

    {

        StartBlock();

        Thread.Sleep(500);

        for (int i = 5; i > 0; i--)

        {

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

            Thread.Sleep(1000);

            GC.Collect();

        }

        Console.WriteLine("Shutting down");

    }

​

    static void StartBlock()

    {

        var block = new ActionBlock<int>(item =>

        {

            Console.WriteLine("Processing an item");

            Thread.Sleep(1000);

        });

        for (int i = 0; i < 10; i++) block.Post(i);

    }

}

​