multifunction_node テンプレート・クラス

概要

receiver<InputType> のテンプレート・クラス。sender<T> の出力のタプルを含みます。このノードには、ユーザーが設定する同時実行数の制限を適用できます。同時実行数の制限が適用されると、着信メッセージのユーザー定義 body を実行します。body は 1 つ以上の出力メッセージを作成してサクセサーにブロードキャストします。

構文

template <typename Input, typename Output, 
    graph_buffer_policy = queueing, typename Allocator=cache_aligned_allocator<Input> >
    class multifunction_node;

ヘッダー

#include "tbb/flow_graph.h"

説明

1 つの入力ポートでメッセージを受け取って、サクセサーにブロードキャストする 1 つ以上のメッセージを生成するノードに使用されます。

multifunction_node は、内部定数しきい値 T と内部カウンター C を維持します。構築時に、C = 0、T はコンストラクターに渡された値に設定されます。try_put 呼び出しの動作は、次の表のように、T と C の値によって決定されます。

multifunction_node には、ユーザーが設定可能な同時実行数の制限が適用されます。flow::unlimited concurrency を指定すると、ノードの無制限のコピーを同時に実行できます。flow::serial concurrency を指定すると、ノードの 1 つのコピーのみ同時に実行できます。同時実行数を制限する size_t 型の値を 1 から unlimited の間で指定することもできます。

multifunction_node のボディーコンセプトを次に示します。

サンプル

下記のサンプルは、整数のストリームを奇数と偶数に分けて適切な出力キューに配置する multifunction_node を示しています。

Body メソッドは、入力値への読み取り専用の参照および出力ポートのタプルへの参照を引数として受け取ります。Body メソッドは 1 つ以上の出力ポートにアイテムを格納することがあります。

multifunction_node の出力ポートは、make_edge メソッドおよび register_successor を使用してほかのグラフのノードに接続できます。

#include "tbb/flow_graph.h"
using namespace tbb::flow;
typedef multifunction_node<int, tbb::flow::tuple<int,int> > multi_node;

struct MultiBody {

  void operator()(const int &i, multi_node::output_ports_type &op) {
    if(i % 2) 
      std::get<1>(op).try_put(i); // 奇数キューに入れる
    else 
      std::get<0>(op).try_put(i); // 偶数キューに入れる
  }
};

int main() {
  graph g;

  queue_node<int> even_queue(g);
  queue_node<int> odd_queue(g);

  multi_node node1(g,unlimited,MultiBody());

  output_port<0>(node1).register_successor(even_queue);
  make_edge(output_port<1>(node1), odd_queue);

  for(int i = 0; i < 1000; ++i) {
    node1.try_put(i);
  }
  g.wait_for_all();
}

メンバー

namespace tbb {
  template <typename Input, typename Output, 
    graph_buffer_policy = queueing, typename Allocator=cache_aligned_allocator<Input> >
    class multifunction_node : public graph_node, public receiver<Input>
  {
  public:

    template < typename Body >
    multifunction_node( graph &g, size_t concurrency, Body body );
    multifunction_node( const multifunction_node &other);
    ~multifunction_node();

    // receiver< Input >
    typedef Input input_type;
    typedef sender<input_type> predecessor_type;
    bool try_put( const input_type &v );
    bool register_predecessor( predecessor_type &p );
    bool remove_predecessor( predecessor_type &p );

    typedef implementation-dependent output_ports_type;
    output_ports_type& output_ports();
  };
}