TPL數據流調用數據流的兩倍

Question

我設計由各種數據塊的數據流複雜。我發送一個數據包到流中，並在最後收到一個結果。

我

input.Post(); 
input.Complete(); 

// and later with 
ReceiveAsync(); 

工作，爲第一次調用一切工作正常，但我不知道如何通過發送第二數據包到流圖。

我也必須使用一個WriteOnceBlock，可這是呼叫的數據流兩倍的問題在圖表上？

Answer 1

在您爲其調用Complete方法或通過完成傳播鏈接到它們的人後，您不能使用TPL Dataflow塊中的任何一個。因此，無論您需要重新創建你的每一個你的電話，或管道（這是首選）不要叫Complete只是一個電話。

建議將您的設計：

• 似乎your're與Post/Receive方法在您的管道，它可以由linking the blocks是替代獲取數據。此外，您可以使用completion propagation for this，因此您將刪除代碼中的所有繼續處理程序（如果有）。
• 你確定你所需要的WriteOnceBlock？你可以將它切換到Broadcast，所以你仍然有一個數據值，但它可以通過下一個電話覆蓋。
• 如果這仍然不是一個選項，您可以解除您的WriteOnceBlock通過指定的MaxMessages for linked blocks或通過存儲LinkTo method的IDisposable結果，所以你可以刪除它爲您的下一個電話，並創建一個新的WriteOnceBlock。