tpl-dataflow

1熱

1答えて

TPL Dataflow Broadcastblockが最後のメッセージを破棄します

私はかなり単純な問題があります。私は、しばらく時間がかかるメッセージに対していくつかの処理を簡単に実行する方法が必要です。処理中に新しい要求が入力される可能性がありますが、最後の要求を除くすべての要求は破棄できます。私は、TPL Broadcastblockは、ドキュメントや記事を見て、よくStackExchangeなどを見ていると思っていました。私は以下のソリューションを作成し、いくつかのユニ

0熱

1答えて

データフローの結果を結合する

私は、ファイルのコレクションを読み込み、各ファイルの各行に対して一連のDataflowブロックを実行するDataflowパイプラインを開発しています。すべてのファイルの中の各行に対してのステップが完了したので、ファイル自体をさらにブロックしたいと思っていますが、これはどのように可能かわかりません。 TransformManyBlockで処理を分割するのは簡単ですが、どうすれば統合できますか？私

2熱

1答えて

リンクされたDataFlowブロックの完了が機能していません

ActionBlockにリンクされたBroadcastBlockがあります。 BroadcastBlockとActionBlockの両方で「完了」と呼ぶと、それは機能しません。ちょうどBroadCastBlockで「完全」と呼んでいるのは機能しています。 public class ActionTester { private readonly ActionBlock<int> _act

1熱

1答えて

TPL Dataflow SendAsync結果

データをTPL Dataflowターゲットに入れるには、PostまたはSendAsyncを使用できます。アイテムがターゲットに配置された場合、すぐに戻ります。私はSendAsyncがそれを入れようともっと長く待つことを理解していますが、を返すSendAsyncの意味は何ですか？ SendAsyncは、ターゲット（具体的には）が完了してより多くのメッセージを受け付けないことを示す信号を返しますか？f

0熱

1答えて

.net dataflowの使用を改善しました

.NET TPLデータフローでコードを整理すると助けが必要です。ここにコードは var finalBlock = new ActionBlock<Category_KeywordsToMatch>(x => { List<Resume> Resumes = new List<Resume>(); using (var context = new IndepthR

0熱

1答えて

TPLラウンドロビンリンクのブロック？

私はTPLをたくさん使用しており、大きなデータフローパイプライン構造を持っています。パイプラインネットワークの一部として、私はいくつかのデータを空白のブロブストレージに書きたいと思っています。私たちはたくさんのデータを持っていますので、4のストレージアカウントがあり、その間にデータを均等に分配したいと考えています。私はSourceBlockを実装したいと思っています。いくつかのターゲットブロッ

1熱

1答えて

TPL DataFlowのパイプライン混乱 - データコールごとに新しいパイプラインを作成する必要がありますか？どのように流れるデータを追跡できますか？

私はアプリケーションにTPL DataFlowを適用する方法に苦労しています。以前はI was just using Tasksというトラッキングと管理を行う並列データ処理がありますが、DataFlowを実装してより詳細な制御を実現しようとしています。私はそれを、データを取得すると言うし、処理するために、タスクのパイプラインを構成していますは、ここでそれは完全なgetデータ、processデー

4熱

1答えて

リアクティブプログラミングを使用してFileStreamを開くために書き込む

私は小さなロガーを作成しています。ログファイルを一度開き、ログメッセージが到着するのを待って書き込み続け、プログラムの終了時にすべてを破棄します。私は、彼らが到着した反動メッセージを書き込むと開いたFileStreamを保つことができるかどうかはわかりませんよ。私はバッファとして動作するConcurrentQueueと、キューを消費したusingステートメント内のループを持つ以前のソリューショ

0熱

1答えて

インテルTBB計算グラフ：ノードの入力キュー容量を指定する方法

.NET TPLデータフローライブラリのC++アナログを探しています。 TPLデータフローでは、並列性&ブロックの容量オプションを指定できます。 ++ var buffer = new BufferBlock<int>(new DataflowBlockOptions() { BoundedCapacity = 10 }); var producer = new Task(() => {

1熱

1答えて

TPL DataFlowがActionBlockで例外を処理できない

ActionBlock<int>から1つのメッセージのコピーを複数のコンシューマ（ActionBlock<int>）に送信しようとしています。これはうまくいきますが、ターゲットブロックの1つが例外をスローすると、ソースブロックには伝播していないようです。ここで私は例外を処理しようとするが、それはcatch部分に行くことはありませんか： static void Main(string[] args)