私はTPLデータフローの完璧なシナリオである必要が生じたプロジェクトに取り組んでいます。比較的限られた経験(私がしていたことはもう少し前に行われました)を持っていたので、私はMicrosoftのドキュメントとオンラインで見つけられる記事を読んでいました。私は見つけることができない(記事に var block1 = new TransformBlock<T, U>(async input => {}
私はDataFlowExを使用していますが、例外がスローされた場合にDataFlow全体をシャットダウンすることはできません。 タスクがランダムに発生するシステムがあります。ネットワークに障害を記録し、その特定のタスクを放棄して他のタスクの実行を続行したいと考えています。 TPLとDataFlowEx両方のドキュメントを読んで 、特に It [a faulted block] should dec
次のTPLデータフローは、述語を使用してTransformBlockからActionBlockに渡されたアイテムをフィルタリングするときに完了しません。 いずれかの項目で述部がfalseを返すと、データフローがハングします。 誰かが何が起こっているか、またこれを解決する方法についていくつかの洞察を提供できますか? // define blocks
var getBlock = new Trans
2つのターゲットブロックにリンクされたBufferBlockがあります。データフローは完了しません。私はthis postからの提案に従っていますが、私は完了の伝播権を得ることができません。 ご協力いただければ幸いです。 // define blocks
var bufferBlock = new BufferBlock<int>();
var actionBlock1 = new Tran
私はActionBlockで以下のような小さなテストメソッドを持っています。トレース・メッセージを予期された順序で書き出しますが、完了することはありません。テストメソッドは決して終了しません。 私はここで間違っていますか?あらかじめThx。 [TestMethod]
public async Task ActionBlockTest()
{
var rnd = new Random(