tpl-dataflow

2熱

1答えて

私は、新しいTasks.Dataflowブロックをネットワーク上で動作させることがどれほど難しいのだろうと思っていました。最善のアプローチは何でしょうか？ WCF RPCを使用してブロックをリンクするか、サードパーティのメッセージング/キューサービスを使用しますか？メッセージをアトミックに消費できますか？私がSQSに持っている問題の1つは、メッセージが正確に1回配信されることを保証しないというこ

0熱

1答えて

このブロックは唯一の私はこの最初のネットワークとTPLデータフローを使用してい

それが作成されたソースと一緒に使用する必要があります。 (a)CustomSource => (b)TransformBlock メッセージがBに到着、bがでブロックを新しいトランスフォームを作成しますフィルタを追加してそれをそれ自身に追加します（各メッセージについてはそうではありません）。ネットワークはそのようになります。ネットワークはそのようになり、いくつかの実行後 (a)CustomS

10熱

3答えて

データフローネットワークでBufferBlock <T>を使用するメリット

ActionBlockに直接ポストするのではなく、（BoundedCapacityを使用して）スロットリング以外のActionBlockにリンクされたBufferBlockを使用する利点があるかどうかは疑問でした。スロットリングが必要ない限り長い間）。

9熱

3答えて

NullReferenceExceptionをスローする非同期ロギング

AsyncTargetingPackを使用して.NET 4.0をターゲットとするMVC 4コントローラアクション内でSQL Serverに非同期に一部の情報を記録しようとしています。私は、.NET 4.5にまっすぐにジャンプするだろうが、私のアプリは、（行がスローなしの例外を除いて、私のデータベースに書き込まれている）予想通りこのコードは動作します...アズールとwe're still wait

16熱

1答えて

見かけBufferBlock.Post/Receive/ReceiveAsyncレース/バグ

http://social.msdn.microsoft.com/Forums/en-US/tpldataflow/thread/89b3f71d-3777-4fad-9c11-50d8dc81a4a9 にクロスポスト...私は本当に、その最大の潜在的にTplDataflowを使用していませんよ。 ATM私は単純に、メッセージの受け渡しに安全なキューとしてBufferBlockを使用しています。こ

14熱

1答えて

Entity Frameworkのと並列

背景私は、定期的なデータダンプ（XMLファイル）を受信し、Entity Frameworkの5（コードファースト）を使用して、既存のデータベースにインポートしたアプリケーションを持っています。エンティティに既に存在するビジネスルールを適用する必要があるため、インポートはBULK INSERTまたはBCPというよりEF5を介して行われます。処理がアプリケーション自体でCPUにバインドされているよ

13熱

1答えて

Reactive Extensions（Rx）上でのTPLデータフローの使用例

私は、いくつかの信号処理アルゴリズムをどちらか一方、あるいは両方の組み合わせで書くことを特に検討しています。パフォーマンスは大きな問題ではなく、意図を表現する明快さがより重要です。私は、次の 'ブロック' を実装し、それらを構成するために探しているはずだ：フィルタ（FIRとIIRの両方）位相検出器インテグレータミキサー機能ジェネレータ PLL（ビルディングブロックとして上記を使用）

10熱

1答えて

これはTPL Dataflowの仕事ですか？

私はかなりの典型的なプロデューサ/コンシューマモデルをさまざまなタスクで実行します。タスク1：バイナリファイルからバイト[]のバッチを読み取り、バイト配列の各コレクションについて新しいタスクを開始します。（この操作はメモリ管理目的でバッチ処理されます）。タスク2-n：これらはワーカー・タスクであり、それぞれバイト配列の渡されたコレクション（Tasks1から）で動作し、バイト配列を逆直列化し、