gpt4 book ai didi

c# - BlockingCollection 使用 TPL 数据流进行批处理

转载 作者:太空狗 更新时间:2023-10-29 22:59:21 25 4
gpt4 key购买 nike

<分区>

有没有办法对阻塞集合中的项目集合进行批处理。例如

我有一个消息传递总线发布者调用 blockingCollection.Add()

还有一个消费线程是这样创建的:

Task.Factory.StartNew(() =>
{
foreach (string value in blockingCollection.GetConsumingEnumerable())
{
Console.WriteLine(value);
}
});

但是,我只希望控制台在阻塞集合上有 10 个项目后写入,而 GetConsumingEnumerable() 总是在添加每个项目后触发。我可以为此编写自己的队列,但我想尽可能使用阻塞集合?

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com