continue_node テンプレート・クラス

概要

graph_node、continue_receiver、sender<T> のテンプレート・クラス。トリガーされると指定されたボディー・オブジェクトを実行し、生成された値をすべてのサクセサーにブロードキャストします。

構文

template< typename Output > class continue_node;

ヘッダー

#include "tbb/flow_graph.h"

説明

実行する前にプレデセッサーの完了を待機するが、入力エッジ間で明示的なデータが渡されないノードに使用されます。ノードの出力は continue_msg または値です。

continue_node は、内部しきい値 T と内部カウンター C を維持します。構築時にプレデセッサー数の値が指定された場合は、T がその値に、C=0 に設定されます。その他の場合は、C=T=0 に設定されます。 

register_predecessor メソッドを呼び出すと、しきい値 T がインクリメントされます。remove_predecessor メソッドを呼び出すと、しきい値 T がデクリメントされます。make_edge および remove_edge 関数は、エッジが continue_node に追加または削除されると、register_predecessor と remove_predecessor を適切に呼び出します。

try_put メソッドを呼び出すと、C がインクリメントされます。インクリメント後に C>=T の場合、C は 0 にリセットされ、タスクは body() の結果をすべてのサクセサーにブロードキャストするためスポーンされます。C のインクリメント、タスクをスポーンする処理、C のリセットはすべて、ノードに関してアトミックに行われます。インクリメントの後に C<T になった場合、追加のアクションは行われません。

ボディー・オブジェクトの実行により生成された値は、すべてのサクセサーにブロードキャストされます。サクセサーがメッセージを拒否した場合、「メッセージ・パッシング・プロトコル」で説明されているプロトコルを使用して処理されます。

continue_node は、グラフのターミナルノードとして動作できます。continue_msg の Output が使用され、サクセサーは接続されません。

Output は、コピー構築可能および代入可能でなければなりません。

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

メンバー

namespace tbb {
namespace flow {
 
template< typename Output >
class continue_node :
  public graph_node, public continue_receiver,
  public sender<Output> {
public:
    template<typename Body>
    continue_node( graph &g, Body body );
    template<typename Body>
    continue_node( graph &g, int number_of_predecessors,
                     Body body );
    continue_node( const continue_node &src );
 
    // continue_receiver
    typedef continue_msg 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 );
 
    // sender<Output>
    typedef Output output_type;
    typedef receiver<output_type> successor_type;
    bool register_successor( successor_type &r );
    bool remove_successor( successor_type &r );
    bool try_get( output_type &v );
    bool try_reserve( output_type &v );
    bool try_release( );
    bool try_consume( );
};
 
}
}