tpl-dataflow

1熱

1答えて

処理する必要があるプロジェクト番号のリストがあります。プロジェクトには約8000個のアイテムがあり、プロジェクトの各アイテムのデータを取得し、このデータをサーバーのリストにプッシュする必要があります。誰でも私に以下を教えてください。 1）私はiRに1000アイテムありますが、サーバーには998個しか書き込まれませんでした。 broadCastBlockを使用してアイテムを失ったのですか？ 2）私は

1熱

1答えて

ActionBlockは、より多くのパラメータを持つ別のActionBlockにリンクできますか？

私はまだTPL DataFlowのハングを取得しているので、私と一緒に熊。私のアプリケーションでは、キューが並行して実行され、その順序は保持されている必要があります。これにより、私はDataFlowライブラリと私が何をしようとしているのかを知ることができました。あるActionBlockを別のActionBlockにリンクする方法があるかどうかと、最初のActionBlockから値を取る方法があ

1熱

1答えて

TPL DataFlowがデータフローを2回呼び出す

さまざまなDataBlockで構成される複雑なデータフローを設計しました。私はフローにパケットを送り、最後に結果を受け取る。私は最初の呼び出しのために input.Post(); input.Complete(); // and later with ReceiveAsync(); で動作するすべてが正常に動作しますが、私はフローグラフに介して第2のデータ・パケットを送信する方法がわ

1熱

1答えて

DataFlowとRXを使用した連続データストリームは処理を停止します

キューからメッセージを無期限に読み込み、RxとTPL DataFlowを使用してメッセージを破棄するシステムをセットアップしました。何らかの理由で、数百のメッセージの後、ActionBlockの実行が停止し、理由を特定できません。 this.GetMessages()は引き続き発砲しますが、this.ProcessMessagesは発動しません。 var source = Observable

3熱

1答えて

例外処理を使用してDataFlow Meshを終了しない方法を作成するには？

私はTPL DataFlowを使用するTaskプロセッサを作成しています。私はプロデューサーの消費者モデルに従います。プロデューサーではしばらくの間処理されるべきアイテムがいくつか生産され、消費者は新しいアイテムが到着するのを待っています。ここに私のコードはあります： async Task Main() { var runner = new Runner(); Cancell

4熱

1答えて

単一の結果を他の複数の結果と結合するデータブロック

私のアプリケーションでは、置換値の辞書で複数の文字列を結合したいと考えています。 readTemplateBlockには、FileInfosが供給され、その内容が文字列として返されます。 getReplacersBlockは、1つの置換え辞書でフィードされます（1回限り）。 joinTemplateAndReplacersBlockはreadTemplateBlockの各項目に1つのgetRepl

1熱

2答えて

DataFlowで重複するアイテムを検出する

私はアイテムを管理するためにQueue<string>オブジェクトを使用してファイルを処理するサービスを構築しています。 public partial class BasicQueueService : ServiceBase { private readonly EventWaitHandle completeHandle = new EventWaitHandle(fa

0熱

2答えて

遅れて送信されたデータフロー

TPL DataFlowに商品を投稿すると、投稿が遅れる可能性のあるメカニズムはありますか？アイテムが処理される前に public partial class BasicDataFlowService { private readonly ActionBlock<string> workerBlock; public BasicDataFlowService()

1熱

1答えて

は、TPLデータフローの同時タスクを識別します

TPLデータフローブロックに1000個の要素があります。各要素は外部Webサービスを呼び出します。 new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 10 ... } Webサービスは、他の同時コールからそれをdistinguises渡された一意のIDを持つように各呼び出しを必要とします。 Web

1熱

1答えて

TPLのデフォルトのコンストラクタBufferBlock：DataFlowBlockOptionsの値

デフォルトのコンストラクタを使用してTPL BufferBlockを構築する場合、DataFlowBlockOptionsは無制限ですか？つまり、BufferBlockのBoundedCapacityは何ですか？ As stated in this SO answerの場合、建設後にBufferBlockの値を照会も変更もできません。