tpl-dataflow

6熱

1答えて

は、私がActionBlockを持つクラスのレシーバーを持ってActionBlock

における非同期ラムダを待つ： public class Receiver<T> : IReceiver<T> { private ActionBlock<T> _receiver; public Task<bool> Send(T item) { if(_receiver!=null) return _receiver.SendAsync(

6熱

1答えて

ハッシュ/シャードされたActionBlocks

私は並列処理が必要な特定のアイテムのフローが一定であるため、TPL Dataflowを使用しています。キャッチは、同じキー（ディクショナリに似ています）を共有するアイテムは、FIFO順で処理され、互いに平行ではなく（異なる値を持つ他のアイテムと平行になることがあります）ということです。作業が行われては、私の解決策はありません並列処理とEnvironment.ProcessorCountのActi

2熱

1答えて

再帰を伴うTPLデータフロー

テストWPFプロジェクトTPLデータフローを使用して特定の親ディレクトリのすべてのサブディレクトリを列挙し、特定のファイル拡張子を持つファイルのリストを作成しようとしています。 ".xlsx"最初のdirToFilesBlockと最後のfileActionBlockの2つのブロックを使用します。すべてのサブディレクトリを通過する再帰的効果を作成するには、最初のブロックに、リンク述語テストを使用し

8熱

1答えて

ActionBlockをカスタマイズする<T>

優先度を実装したいActionBlock<T>。だから私はPredicate<T>を使って条件付きでいくつかのTInputアイテムに優先順位をつけることができます。私は Parallel Extensions Extras SamplesとGuide to Implementing Custom TPL Dataflow Blocksを読みました。しかし、このシナリオをどのように実装すればよい

2熱

1答えて

tplデータフローブロックでスローされたOperationCanceledExceptionが取り込まれる

OperationCanceledExceptionがIDataflowBlockの内部にスローされる何らかの理由により、ブロックはこの例外をIDataflowBlock.Completionタスクに伝播しません。以下のコードサンプルを実行すると、予期しない結果が返されます。IDataflowBlock.Completion.Status == TaskStatus.RanToCompletion

52熱

2答えて

再試行可能ブロックの正しい完了の実装

Teaser：皆さん、この質問は再試行ポリシーの実装方法に関するものではありません。それは、TPLデータフローブロックが正しく完了したことです。この質問は、ほとんど前の質問Retry policy within ITargetBlockの続きです。この質問に対する答えは、TransformBlock（ソース）とTransformManyBlock（ターゲット）を使用する@ svickのスマートな

2熱

2答えて

ActionBlock <T>対Task.WhenAll

複数の非同期メソッドを並行して実行するために推奨される方法は何ですか？ in System.Threading.Tasks.Dataflow最大並列度を指定できますが、無制限はおそらくTask.WhenAllのデフォルトですか？この： var tasks = new List<Task>(); foreach(var item in items) { tasks.Add(myAsy

5熱

1答えて

タスクデータフロー、データブロックを完了状態から変更できますか？

データブロックの完了状態を変更することが可能かどうかを知りたいですか？たとえば、block.Complete()と書かれたvar block = new BufferBlock<int>();データブロックをマークしました。ブロックは他のデータブロックにリンクされています。私はblockを完了状態を元の！complete状態に戻して再実行できるかどうかを知りたいと思います。 a）すべてのブロック

9熱

1答えて

予期しない動作 - TPL DataFlow BatchBlockは、TriggerBatchの実行中にアイテムを拒否します。

バインドされた容量のバッチブロックを作成し、triggerBatchを呼び出して新しいアイテムをポストすると、トリガーのバッチ実行中に新しいアイテムが失敗します。呼び出しトリガーバッチ（X回ごと）は、受信データストリームが一時停止または遅くなった場合に、データがブロック内で長すぎないようにするために行われます。次のコードは、「失敗後」イベントを出力します。たとえば： public stati

20熱

4答えて

TPLデータフロー、すべてのソースデータブロックが完了したときのみ完了を保証

両方の変換ブロックが完了したときにコードが完了するコードを再書き込みするにはどうすればよいですか？完了とは、完了とマークされ、「アウトキュー」が空であることを意味します。 public Test() { broadCastBlock = new BroadcastBlock<int>(i => { return i; });