tpl-dataflow

3熱

1答えて

私のC＃BlockingCollectionベースのコードをTPLデータフローに変換する

私はTPLデータフローを使用して解決できると確信している特定の問題があります。私はちょうどこれに新しいので、あなたの助けが私の理解を急ぐ必要があります。プロセス1、プロセス2、Process3各タスクです：私のコードは、現在、このようなものです。オブジェクトはブロックコレクションから別のブロックに渡されます。私はこれをやりたい：私はあなたがどのように設計上達成するために、これらのクラスを使用す

2熱

2答えて

TPLデータフローパイプが常にサービス例えば

内で実行されている、私は三つのブロックを持っています。アクションブロックでCompletion（）を呼び出しずにパイプ全体を停止することなく永遠に実行されるようなパイプを作成する方法。

3熱

2答えて

TPLデータフローループの完了

ループするTPLデータフロー内の完了を検出する方法を決定する際に問題があります。 GETリクエストをリモートサーバーに送信し、データレスポンスを処理しているデータフローの一部にフィードバックループがあります（データフローをさらに変換して結果をコミットする）。データソースは、その結果を1000レコードのページに分割し、使用可能なページの数を教えません。私はちょうど私がデータの完全なページより少なく

6熱

2答えて

TransformBlockの出力への出力

私のシナリオでは、BufferBlock<Stream>が外部ソースからStreamを受け取っています。ファイルシステムまたはFTPサーバーとしましょう。これらのファイルStreamは、別のブロックに渡され、処理されます。これらのファイルのいくつかは圧縮されており、必要に応じてファイルを解凍する中間にBlockを追加して、それぞれのエントリに対して複数の出力Streamを作成したいと思います。

4熱

1答えて

.NET待機タスク（async/await）

私は、実行する必要があるタスク（〜1000）が非常に多いです。私は4コアプロセッサで動作しているので、同時に4つのタスクを並行して処理したいと思います。出発点として、ここにいくつかのサンプルコードを示します。 class Program { public class LongOperation { private static readonly Random R

1熱

1答えて

TPLデータフロー - 条件付きループ

現在、私はパイプラインのデータフローに取り組んでいます。ステージ1以外の各ステージはコンシューマとプロデューサを実行するasyncです。私は、アイテムを参照する私のパイプラインを流れる "オブジェクト"を持っています。ステージ3では、特別な条件（ステージループ）を満たすすべてのオブジェクトをループしてバッファしたいと考えています。現在バッファリングされている他のオブジェクト（ステージループ）があ

2熱

1答えて

TPLデータフロー - 非常に速いプロデューサー、非常に高速なコンシューマーOutOfMemory例外

私はTPL Dataflowをプロダクションコードに移植する前に実験しています。プロダクションコードは古典的なプロデューサ/コンシューマシステムです。プロデューサは（金融ドメインに関連して）メッセージを生成し、コンシューマはそれらのメッセージを処理します。私が興味を持っているのは、ある時点でプロデューサーが消費者よりもはるかに速く生産するならば、安定した環境が維持されることです（システムが爆発