System.Threading.Channels é uma biblioteca dotnet que fornece uma API de canal de comunicação de dados baseada em buffer para sincronização de threads. Essa biblioteca permite que você transmita dados de forma segura e sincronizada entre threads, tornando mais fácil criar aplicativos multithread de alta performance.
O canal é criado usando uma das implementações fornecidas, como o canal simples ou o canal limitado em tamanho de buffer, e pode ser usado para enviar e receber valores. As operações de envio e recebimento são bloqueadas até que haja espaço disponível no buffer ou até que um valor esteja disponível, respectivamente. Isso garante que as threads sejam sincronizadas e evita o famigerado racing condition.
Além disso, os canais também fornecem suporte a cancelamentos, o que significa que você pode interromper uma operação de envio ou recebimento em andamento se necessário.
Um exemplo singelo de como usar um canal simples para transmitir dados entre duas threads:
using System;
using System.Threading.Channels;
using System.Threading.Tasks;
var channel = Channel.CreateUnbounded<int>(/*Você pode informar uma quantidade máxima de items a serem processados*/);
// Inicia a primeira thread para enviar dados ao canal
var sender = Task.Run(async () =>
{
for (int i = 0; i < 5; i++)
{
Console.WriteLine("Sender enviando: " + i);
await channel.Writer.WriteAsync(i);
}
channel.Writer.Complete();
});
// Inicia a segunda thread para receber dados do canal
var receiver = Task.Run(async () =>
{
while (await channel.Reader.WaitToReadAsync())
{
if (channel.Reader.TryRead(out int item))
{
Console.WriteLine("Receiver recebendo: " + item);
}
}
});
await Task.WhenAll(sender, receiver);
Console.WriteLine("Todas as mensagens foram transmitidas e recebidas.");
No exemplo acima, criamos um canal simples usando Channel.CreateUnbounded() e iniciamos duas threads. A primeira thread usa o método WriteAsync do canal para enviar valores inteiros e a segunda thread usa o método WaitToReadAsync e TryRead para receber os valores enviados. Quando a primeira thread chama channel.Writer.Complete(), isso indica que não haverá mais valores a serem transmitidos e a segunda thread para de esperar por novos dados.
Sem dúvida, o System.Threading.Channels é uma ferramenta poderosa para sincronização de threads no dotnet, que fornece uma API simples e eficiente para garantir que as threads sejam sincronizadas ao transmitir dados.
Se você estiver trabalhando em um aplicativo multithread, considere usar o System.Threading.Channels para simplificar a sincronização de threads e melhorar o desempenho do seu aplicativo.
Recomendo esse ótimo post: An Introduction to System.Threading.Channels — .NET Blog (microsoft.com)
A documentação é bem completa e recomendo muito a leitura: Channels — .NET | Microsoft Learn
Você já usou? Se sim, compartilha conosco o seu caso de uso :)
Até a próxima!
Top comments (0)