Организуем неблокирующий продюсер–консюмер с ChannelReader/Writer!

При обмене данными между задачами часто нужно передавать данные по мере готовности, без блокировок и ручных очередей. Вместо lock или BlockingCollection используем Channel — асинхронный и безопасный способ обмена сообщениями.

Сначала создаём канал без ограничений на размер — данные будут накапливаться в памяти:

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

Запускаем продюсера: он будет отправлять сообщения в канал с небольшой задержкой:

_ = Task.Run(async () =>
{
    for (int i = 1; i <= 5; i++)
    {
        await Task.Delay(500);
        await channel.Writer.WriteAsync($"Msg #{i}");
        Console.WriteLine($"Отправлено: Msg #{i}");
    }
    channel.Writer.Complete();
});

Теперь читаем данные по мере поступления через await foreach — потребитель не блокируется и реагирует на каждое новое сообщение:

await foreach (var msg in channel.Reader.ReadAllAsync())
{
    Console.WriteLine($"Принято: {msg}");
}

🔥 Получаем асинхронную очередь: безопасную, читаемую и без ручных синхронизаций.

➡️ C# Ready | #практика

❤️ Советую вам ILSpy — это популярный бесплатный декомпилятор для .NET

С его помощью можно изучать исходный код сборок, исследовать внутренности библиотек и разбирать чужие проекты без доступа к исходникам. Поддерживает просмотр C#, IL-кода, поиск по сборкам и плагины для расширения функциональности.

Оставляю ссылочку: GitHub 📱

➡ C# Ready | #ресурс