ネタ元：インテルTBB 3.0によるパイプライン処理
επιστημηさんの記事です。TBB3.0(VS2010環境だとラムダOK)で新たに加わったパイプライン関数のお話です。
パイプライン処理って何？という人は元記事見てください(１ページ目だけでも十分ですが、３ページ目最後の実行結果が並列並列してていい感じですｗ)。
ということで、さっそくPPLに移植しました。といっても、PPLにはパイプラインの仕組みそのものはありません。なので、別途agents ライブラリにある、非同期メッセージのtransferオブジェクトを使って実装します(まぁ、これを数珠つなぎにするのがパイプラインなんですがｗ)。
感じとしては、３ページ目の make_filter() を直接渡すではなく、それでオブジェクトを作っておいて、それぞれをつないでいくという感じです。
そして、最後に明示的にメッセージを送ってやれば、あとは粛々と処理を行ってくれます。もちろん、並列に。。。
エントリー見たのが、３時ころだったかな？ちなみに今の時点で５時半です。
２時間ばかりはまってました。。。だって、結果でねーんだもの...orz
ということで、こいつもありがたーくいただきました。
結果は、6/26 のわんくま同盟東京勉強会 に持っていきますよ。やるかどうかは当日の皆さんの心意気次第ですがｗ