using System;

using System.Diagnostics;

using System.Threading;

using System.Threading.Channels;

using System.Threading.Tasks;

using System.Threading.Tasks.Dataflow;

​

public static class Program

{

    public static async Task Main()

    {

        var channel = Channel.CreateUnbounded<int>();

        var bufferBlock = new BufferBlock<int>();

        var asyncCollection = new Nito.AsyncEx.AsyncCollection<int>();

        var mem0 = GC.GetTotalMemory(true);

        int timeouts = 0;

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

        {

            var stopwatch = Stopwatch.StartNew();

            while (stopwatch.ElapsedMilliseconds < 500)

            {

                using var cts = new CancellationTokenSource(1);

                try

                {

                    await channel.Reader.ReadAsync(cts.Token);

                    //await bufferBlock.ReceiveAsync(cts.Token);

                    //await asyncCollection.TakeAsync(cts.Token);

                }

                catch (OperationCanceledException) { timeouts++; }

            }

            var mem1 = GC.GetTotalMemory(true);

            Console.WriteLine($"{i + 1,2}) Timeouts: {timeouts,5:#,0},"

                + $" Allocated: {mem1 - mem0:#,0} bytes");

        }

    }

}

​