bufferblock

0热度

1回答

TPL BufferBlock食用方法不会被调用

我想要实现使用持续运行类似问题here和代码here的BufferBlock消费者/生产模式。 我试图使用类似于OP的ActionBlock，但是如果bufferblock已满并且新消息位于其队列中，则新消息永远不会添加到ConcurrentDictionary _queue中。 在ConsumeAsync方法时，一个新的消息添加到与该呼叫的bufferblock不会被调用下面的代码：_messa

c# multithreading task-parallel-library tpl-dataflow bufferblock 2017-09-09

---

1热度

1回答

ActionBlock开始或结束时是否从BufferBlock中删除项目？

假设我有一个有限容量为2的BufferBlock，我将它与MaxDegreeOfParallelism = 2链接（使用LinkTo()）一个ActionBlock。现在，我知道我将立即能够发送2个项目到缓冲区，并且ActionBlock将会立即开始处理它们。但让我们说这些行动需要几秒钟才能完成。当那些首先执行的动作正在运行时，或者是仅在消耗完操作后才从缓冲区中删除的项目，我才能够将另外2个项目发

c# task-parallel-library tpl-dataflow bufferblock 2017-04-26

---