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

---