limiter_node テンプレート・クラス

概要

ノードに渡されるメッセージの数をカウントおよび制限するノード。

構文

template < typename T > class limiter_node;

ヘッダー

#include "tbb/flow_graph.h"

説明

limiter_node は、メッセージをすべてのサクセサーにブロードキャストする graph_node、receiver<T>、sender<T> です。ブロードキャストする数のカウンター C を維持して、ユーザー定義の threshold に達すると、新しいメッセージを受け付けなくなります。ブロードキャスト C の内部カウントは、continue_receiver decrement を使用してデクリメントできます。

limiter_node の try_put 呼び出しの動作を下記に示します。

try_put がメンバー・オブジェクト decrement で呼び出されると、limiter_node は既知のプレデセッサーの 1 つからメッセージを取得して、そのメッセージをすべてのサクセサーに転送しようとします。プレデセッサーからメッセージを取得できない場合、C をデクリメントします。サクセサーがメッセージを拒否した場合、およびプレデセッサーからのメッセージの取得に失敗した場合、「メッセージ・パッシング・プロトコル」で説明されているプロトコルを使用して処理されます。

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

メンバー

namespace tbb {
namespace flow {
 
template< typename T >
class limiter_node : public graph_node, public receiver<T>,
  public sender<T> {
public:
    limiter_node( graph &g, size_t threshold,
                  int number_of_decrement_predecessors = 0 );
    limiter_node( const limiter_node &src );
 
    // continue_receiver
    implementation-dependent-type decrement;
 
    // receiver<T>
    typedef T 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<T>
    typedef T 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( );
};
 
}
}