Hello World System.Threading.Channels

Program.cs

using System;
using System.Threading;
using System.Threading.Channels;
using System.Threading.Tasks;

class Program
{
    public static async Task Main(string[] args)
    {
        var channel =
            Channel.CreateBounded<int>(
                new BoundedChannelOptions(100)
                {
                    FullMode = BoundedChannelFullMode.Wait,
                    SingleReader = true,
                    SingleWriter = true,
                    AllowSynchronousContinuations = false
                });

        Task.Run(
            async () =>
            {
                for (var i = 0; i < 100; i++)
                {
                    Console.WriteLine($" Writing {i} on Thread {Thread.CurrentThread.ManagedThreadId}");
                    await channel.Writer.WriteAsync(i);
                    await Task.Delay(500);
                }

                channel.Writer.Complete();
            });

        Task.Run(
            async () =>
            {
                try
                {
                    while (true)
                    {
                        var item = await channel.Reader.ReadAsync();
                        Console.WriteLine($"Received {item} on Thread {Thread.CurrentThread.ManagedThreadId}");
                    }
                }
                catch (ChannelClosedException)
                {
                }
            });

        await channel.Reader.Completion;
        Console.WriteLine("Completed!");
        Console.ReadLine();
    }
}