小编The*_*ger的帖子

BlockingCollection <T>使用TPL DataFlow进行批处理

有没有办法批量阻止集合中的项集合.例如

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

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

Task.Factory.StartNew(() =>
        {
            foreach (string value in blockingCollection.GetConsumingEnumerable())
                {
                    Console.WriteLine(value);
                }
        });
Run Code Online (Sandbox Code Playgroud)

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

c# task-parallel-library blockingcollection

5
推荐指数
1
解决办法
916
查看次数