tpl-dataflow

    -1

    2答えて

    2番目のコードブロックでアクションブロックの完了を待っているときに、最初のコードブロックがなぜスローされるのか説明できますか?データフローブロックの連鎖はないので、伝播は必要ありません。 ActionBlock定義1: ActionBlock<int> workerBlock = new ActionBlock<int>(async (i) => { await Task.Delay(

    2

    1答えて

    私はDataFlowExを使用していますが、例外がスローされた場合にDataFlow全体をシャットダウンすることはできません。 タスクがランダムに発生するシステムがあります。ネットワークに障害を記録し、その特定のタスクを放棄して他のタスクの実行を続行したいと考えています。 TPLとDataFlowEx両方のドキュメントを読んで 、特に It [a faulted block] should dec

    2

    1答えて

    オープンソースのライブラリDataflowExを次のDataflow宣言で使用しようとしています。 AAAA 18 | 54.3773:32:32:私は var requestClientFlow = new RequestClientFlow(this); requestClientFlow.Post(""); requestClientFlow.Complete(); await req

    0

    1答えて

    実際にTPLデータフローの問題が発生しています(アイテムが2回追加されたようです)。したがって、アイテムがターゲットブロックに投稿されている場合、ロギングに使用できるコールバックを挿入するオプションがあるかどうかを知りたかったのです。 ActionBlock、BufferBlockのコンストラクタ、およびLinkToのメソッドをチェックしましたが、何も見つかりませんでした。 ヒント

    3

    1答えて

    レガシーDBから顧客関連データをインポートし、プロセス中にいくつかの変換を実行する必要があります。これは、単一のエントリが追加の "イベント"(製品の同期化、請求書の作成など)を実行する必要があることを意味します。 私の初期の解決策は、単純な並列アプローチでした。 問題なく動作しますが、時にはとなります。現在処理されている顧客が同じタイプのイベントを待つ必要がある場合、処理キューがスタックして最終

    0

    1答えて

    次のTPLデータフローは、述語を使用してTransformBlockからActionBlockに渡されたアイテムをフィルタリングするときに完了しません。 いずれかの項目で述部がfalseを返すと、データフローがハングします。 誰かが何が起こっているか、またこれを解決する方法についていくつかの洞察を提供できますか? // define blocks var getBlock = new Trans

    0

    1答えて

    2つのターゲットブロックにリンクされたBufferBlockがあります。データフローは完了しません。私はthis postからの提案に従っていますが、私は完了の伝播権を得ることができません。 ご協力いただければ幸いです。 // define blocks var bufferBlock = new BufferBlock<int>(); var actionBlock1 = new Tran

    1

    1答えて

    私はActionBlockで以下のような小さなテストメソッドを持っています。トレース・メッセージを予期された順序で書き出しますが、完了することはありません。テストメソッドは決して終了しません。 私はここで間違っていますか?あらかじめThx。 [TestMethod] public async Task ActionBlockTest() { var rnd = new Random(

    -1

    1答えて

    TPL Dataflowをよく理解するための簡単なプログラムを作成しようとしています。私はそれが完了している場合、データフローブロックを再起動する長期実行タスクを作成しようとしています。 私の現在のRestartActionBlockタスクは、 "-1"と入力してブロックを完全に呼び出すと、ActionBlockの完了を待つことができます。しかし、ブロックをフォルトするための例外を発生させようとし

    0

    1答えて

    私はTPLデータフローの完璧なシナリオである必要が生じたプロジェクトに取り組んでいます。比較的限られた経験(私がしていたことはもう少し前に行われました)を持っていたので、私はMicrosoftのドキュメントとオンラインで見つけられる記事を読んでいました。私は見つけることができない(記事に var block1 = new TransformBlock<T, U>(async input => {}