using System;

​

using System.Threading.Tasks;

using System.Threading.Tasks.Dataflow;

public class Program

{

    public static void Main()

    {

        Console.WriteLine("Hello World");

        BatchBlock<string> batcher = new BatchBlock<string>( 10 );

        ActionBlock<string[]> consumer = new ActionBlock<string[]>( (msgs) => Console.WriteLine("Processed {0} messages.", msgs.Length) );

        batcher.LinkTo( consumer );

        Parallel.For( 0, 103, (i) => batcher.Post(string.Format("Test {0}",i)));

        batcher.Complete();

        batcher.Completion.Wait();

    }

}