Introdução ao Channel - Parte 1

public class Produto
{
    public string SKU { get; set; }
    public string Descricao { get; set; }
    public decimal Preco { get; set; }
    public int Estoque { get; set; }
}

public class BrokerFake
{
    public static async ValueTask SendAsync<T>(T data)
    {
        var message = JsonSerializer.Serialize(data);

        // Simular latência de 10 milissegundos
        await Task.Delay(TimeSpan.FromMilliseconds(10));
    }
} 

public class ChannelTest<T>
{
    private readonly Channel<T> _channel;
    private bool _runningConsummer;
    private bool _stopRequested;

    public ChannelTest()
    {
        _channel = Channel.CreateBounded<T>(1000);
    }

    public async ValueTask Enqueue(T data) 
        => await _channel.Writer.WriteAsync(data).ConfigureAwait(false);

    public async Task Consumer()
    {
        while (true)
        {
            if(_stopRequested && _channel.Reader.Count == 0)
            {
                break;
            }

            if(_channel.Reader.Count == 0)
            {
                await Task.Delay(10);

                continue;
            }

            if (_channel.Reader.TryRead(out var item))
            {
                await BrokerFake.SendAsync(item);
            }
        }
    }

    public void StartConsumers()
    {
        Task.Run(() =>
        {
            var tasks = new Task[6];

            for (int i = 0; i < tasks.Length; i++)
            {
                tasks[i] = Consumer();
            }

            _runningConsummer = true;

            Task.WaitAll(tasks);

            _runningConsummer = false;
        });
    }

    public void Complete()
    {
        _stopRequested = true;

        while (_runningConsummer) 
        { 
            Task.Delay(10).Wait(); 
        };
    }
}

[MemoryDiagnoser]
public class Performance
{
    private static IEnumerable<Produto> GetProdutos()
    {
        var produtos = Enumerable.Range(1, 1000)
            .Select(p => new Produto
            {
                SKU = Guid.NewGuid().ToString("N"),
                Descricao = $"Produto {p}",
                Preco = (p * 1.1m),
                Estoque = p
            });

        return produtos;
    }

    [Benchmark]
    public async ValueTask SemChannel()
    {
        foreach (var produto in GetProdutos())
        {
            await BrokerFake.SendAsync(produto);
        }
    }

    [Benchmark]
    public async ValueTask ComChannel()
    {
        var channel = new ChannelTest<Produto>();
        channel.StartConsumers();

        foreach (var produto in GetProdutos())
        {
            await channel.Enqueue(produto);
        }

        channel.Complete();
    }
}