Concurrency in C# Cookbook、第 2 版

第5章 データフローの基本 データフローの基本

この作品はAIを使って翻訳されている。ご意見、ご感想をお待ちしている：[e-mail]

TPLDataflowは、メッシュやパイプラインを作成し、そこに（非同期に）データを送ることができる強力なライブラリである。通常、まずメッシュを完全に定義してからデータ処理を始める。メッシュは結局、データが流れる構造になっている。このため、アプリケーションについて少し違った考え方をする必要があるが、一度その飛躍をすれば、データフローは多くのシナリオに自然に適合するようになる。

各メッシュは、互いにリンクされた様々なブロックで構成されている。個々のブロックはシンプルで、データ処理の単一ステップを担当する。あるブロックがデータ処理を終えると、その結果をリンクしているブロックに渡す。

TPL Dataflowを使用するには、NuGetパッケージをアプリケーションにインストールする。 System.Threading.Tasks.Dataflowをアプリケーションにインストールする。

5.1 ブロックのリンク

問題

メッシュを作成するには、データフロー・ブロックを互いにリンクさせる必要がある。

解決策

TPL Dataflowライブラリが提供するブロックは、最も基本的なメンバーのみを定義している。便利なTPL Dataflowメソッドの多くは、実際には拡張メソッドである。LinkTo 拡張メソッドは、データフローブロックを一緒にリンクする簡単な方法を提供する：

var multiplyBlock = new TransformBlock<int, int>(item => item * 2);
var subtractBlock = new TransformBlock<int, int>(item => item - 2);

// After linking, values that exit multiplyBlock will enter subtractBlock.
multiplyBlock.LinkTo(subtractBlock);

デフォルトでは、リンクされたデータフロー・ブロックはデータのみを伝搬し、完了（またはエラー）は伝搬しない。データフローが（パイプラインのように）線形である場合、おそらく完了を伝播したいだろう。完了（とエラー）を伝播するには、リンクにPropagateCompletion オプションを設定する：

var multiplyBlock = new TransformBlock<int, int>(item => item * 2);
var subtractBlock = new TransformBlock<int, int>(item => item - 2);

var options = new DataflowLinkOptions { PropagateCompletion = true };
multiplyBlock.LinkTo(subtractBlock, options);

...

// The first block's completion is automatically propagated to the second block.
multiplyBlock.Complete();
await subtractBlock.Completion;

ディスカッション

がリンクされると、ソースブロックからターゲットブロックへ自動的にデータが流れる。 ...