static async Task Main(string[] args)
    {
        var channel = Channel.CreateUnbounded<int>();
        var producer = Task.Run(async () =>
        {
            for (int i = 0; i < 10; i++)
            {
                await channel.Writer.WriteAsync(i);
                await Task.Delay(1000); // 模擬生產(chǎn)者需要一些時(shí)間來(lái)生成數(shù)據(jù)
            }
            channel.Writer.Complete();
        });
        var consumer = Task.Run(async () =>
        {
            await foreach (var item in channel.Reader.ReadAllAsync())
            {
                Console.WriteLine($"消費(fèi)者接收到: {item}");
            }
        });
        await Task.WhenAll(producer, consumer);
    }

    static async Task Main(string[] args)
    {
        var channel = Channel.CreateBounded<int>(5); // 創(chuàng)建一個(gè)容量為5的有界通道
        var producer = Task.Run(async () =>
        {
            for (int i = 0; i < 10; i++)
            {
                await channel.Writer.WriteAsync(i);
                Console.WriteLine($"生產(chǎn)者生成了: {i}");
                await Task.Delay(1000); // 模擬生產(chǎn)者需要一些時(shí)間來(lái)生成數(shù)據(jù)
            }
            channel.Writer.Complete();
        });
        var consumer = Task.Run(async () =>
        {
            await foreach (var item in channel.Reader.ReadAllAsync())
            {
                Console.WriteLine($"消費(fèi)者接收到: {item}");
                await Task.Delay(2000); // 模擬消費(fèi)者需要一些時(shí)間來(lái)處理數(shù)據(jù)
            }
        });
        await Task.WhenAll(producer, consumer);
    }

    static async Task Main(string[] args)
    {
        var channel = Channel.CreateUnbounded<int>();
        // 創(chuàng)建兩個(gè)生產(chǎn)者
        var producer1 = Produce(channel.Writer, id: 1);
        var producer2 = Produce(channel.Writer, id: 2);
        // 創(chuàng)建兩個(gè)消費(fèi)者
        var consumer1 = Consume(channel.Reader, id: 1);
        var consumer2 = Consume(channel.Reader, id: 2);
        // 等待所有生產(chǎn)者和消費(fèi)者完成
        await Task.WhenAll(producer1, producer2, consumer1, consumer2);
    }
    static async Task Produce(ChannelWriter<int> writer, int id)
    {
        for (int i = 0; i < 10; i++)
        {
            await writer.WriteAsync(i);
            Console.WriteLine($"生產(chǎn)者{id}生成了: {i}");
            await Task.Delay(1000); // 模擬生產(chǎn)者需要一些時(shí)間來(lái)生成數(shù)據(jù)
        }
        writer.Complete();
    }
    static async Task Consume(ChannelReader<int> reader, int id)
    {
        await foreach (var item in reader.ReadAllAsync())
        {
            Console.WriteLine($"消費(fèi)者{id}接收到: {item}");
            await Task.Delay(2000); // 模擬消費(fèi)者需要一些時(shí)間來(lái)處理數(shù)據(jù)
        }
    }