namespace System.Threading.Channels
{
    public abstract class Channel<T> : Channel<T, T> { }
}

Channel<T> CreateUnbounded<T>();
Channel<T> CreateUnbounded<T>(UnboundedChannelOptions options);
Channel<T> CreateBounded<T>(int capacity);
Channel<T> CreateBounded<T>(BoundedChannelOptions options);

Channel<int> channel = Channel.CreateUnbounded<int>();
//Можно делать так
ChannelWriter<int> writer = channel.Writer;
ChannelReader<int> reader = channel.Reader;
//Или так
ChannelWriter<int> writer = channel;
ChannelReader<int> reader = channel;

Channel<int> unboundedChannel = Channel.CreateUnbounded<int>();
//Объекты ниже можно отправить в разные потоки, которые будут использовать их независимо в своих целях
ChannelWriter<int> writer = unboundedChannel;
ChannelReader<int> reader = unboundedChannel;
//Первый поток может писать в канал
int objectToWriteInChannel = 555;
await writer.WriteAsync(objectToWriteInChannel);
//И завершить его, при исключении или в случае, когда записал все, что хотел
writer.Complete();
//Второй может читать данные из канала по мере их доступности
int valueFromChannel = await reader.ReadAsync();

public static T CompareExchange<T>(ref T location1, T value, T comparand) where T : class;

class Program
    {
        static async Task Main(string[] args)
        {
            Channel<int> unboundedChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions
            {
                AllowSynchronousContinuations = true
            });
            ChannelWriter<int> writer = unboundedChannel;
            ChannelReader<int> reader = unboundedChannel;
            Console.WriteLine($"Main, before await. Thread id: {Thread.CurrentThread.ManagedThreadId}");
            var writerTask = Task.Run(async () =>
            {
                Thread.Sleep(500);
                int objectToWriteInChannel = 555;
                Console.WriteLine($"Created thread for writing with delay, before await write. Thread id: {Thread.CurrentThread.ManagedThreadId}");
                await writer.WriteAsync(objectToWriteInChannel);
                Console.WriteLine($"Created thread for writing with delay, after await write. Thread id: {Thread.CurrentThread.ManagedThreadId}");
            });
            //Blocked here because there are no items in channel
            int valueFromChannel = await reader.ReadAsync();
            Console.WriteLine($"Main, after await (will be processed by created thread for writing). Thread id: {Thread.CurrentThread.ManagedThreadId}");
            await writerTask;
            Console.Read();
        }
    }