フリーズしないアプリケーションの作り方：特集：.NET開発者のための非同期入門（3/3 ページ）

public static int Run(int a, int b, int c)
{
  int p, q, r, s, t, u, v, x;
 
  処理1(a, out p, out q);
  処理4(p, out t, out u);
  処理2(b, t, out r);
  処理3(c, out s);
  処理5(q, r, out v);
  処理6(s, u, v, out x);
 
  return x;
}

static ISourceBlock<int> Asign(ISourceBlock<int> a, ISourceBlock<int> b, ISourceBlock<int> c)
{
  var p = new BufferBlock<int>();
  var q = new BufferBlock<int>();
  var r = new BufferBlock<int>();
  var s = new BufferBlock<int>();
  var t = new BufferBlock<int>();
  var u = new BufferBlock<int>();
  var v = new BufferBlock<int>();
  var x = new BufferBlock<int>();
 
  Asign(a, 処理1, p, q);
  Asign(b, t, 処理2, r);
  Asign(c, 処理3, s);
  Asign(p, 処理4, t, u);
  Asign(q, r, 処理5, v);
  Asign(s, u, v, 処理6, x);
 
  return x;
}
 
static void Asign<X1, X2, Y1, Y2>(ISourceBlock<X1> x1, ISourceBlock<X2> x2, Func<Tuple<X1, X2>, Tuple<Y1, Y2>> f, ITargetBlock<Y1> y1, ITargetBlock<Y2> y2)
{
  var x = Join(x1, x2);
  var y = Broadcast<Y1, Y2>(y1, y2);
  Asign(x, f, y);
}

……中略…… // 似たようなメソッドがいくつか

static void Asign<X, Y>(ISourceBlock<X> x, Func<X, Y> f, ITargetBlock<Y> y)
{
  var t = new TransformBlock<X, Y>(f);
  x.LinkTo(t);
  t.LinkTo(y);
}

private static ITargetBlock<Tuple<Y1, Y2>> Broadcast<Y1, Y2>(ITargetBlock<Y1> y1, ITargetBlock<Y2> y2)
{
  var t1 = new TransformBlock<Tuple<Y1, Y2>, Y1>(_ => _.Item1);
  var t2 = new TransformBlock<Tuple<Y1, Y2>, Y2>(_ => _.Item2);
  var y = new BroadcastBlock<Tuple<Y1, Y2>>(i => i);
  y.LinkTo(t1);
  y.LinkTo(t2);
  t1.LinkTo(y1);
  t2.LinkTo(y2);
  return y;
}
 
private static ISourceBlock<Tuple<X1, X2>> Join<X1, X2>(ISourceBlock<X1> x1, ISourceBlock<X2> x2)
{
  var x = new JoinBlock<X1, X2>();
  x1.LinkTo(x.Target1);
  x2.LinkTo(x.Target2);
  return x;
}