unbounded_buffer クラス

unbounded_buffer メッセージング ブロックは、メッセージを無制限に格納することができる、複数のターゲットと複数のソースを持つ順序付けられた propagator_block です。

template<
   class _Type
>
class unbounded_buffer : public propagator_block<multi_link_registry<ITarget<_Type>>, multi_link_registry<ISource<_Type>>>;

パラメーター

• _Type
  このバッファーが格納し、反映するメッセージのペイロード型。

メンバー

パブリック コンストラクター

名前	Description
unbounded_buffer::unbounded_buffer コンストラクター	オーバーロードされます。unbounded_buffer メッセージング ブロックを構築します。
unbounded_buffer::~unbounded_buffer デストラクター	unbounded_buffer メッセージング ブロックを破棄します。

パブリック メソッド

名前	Description
unbounded_buffer::dequeue メソッド	unbounded_buffer メッセージング ブロックから項目を削除します。
unbounded_buffer::enqueue メソッド	項目を unbounded_buffer メッセージング ブロックに追加します。

プロテクト メソッド

名前	Description
unbounded_buffer::accept_message メソッド	この unbounded_buffer メッセージング ブロックによって提供されたメッセージを受け入れ、所有権を呼び出し元に移譲します。
unbounded_buffer::consume_message メソッド	この unbounded_buffer メッセージング ブロックによって以前に提供され、ターゲットによって予約されたメッセージを使用して、所有権を呼び出し元に移譲します。
unbounded_buffer::link_target_notification メソッド	新しいターゲットがこの unbounded_buffer メッセージング ブロックにリンクされたことを通知するコールバックです。
unbounded_buffer::process_input_messages メソッド	message_PMessage をこの unbounded_buffer メッセージング ブロックに配置し、それをリンクされたすべてのターゲットに提供することを試みます。
unbounded_buffer::propagate_message メソッド	ISource ブロックからこの unbounded_buffer メッセージング ブロックにメッセージを非同期に渡します。このメソッドは、ソース ブロックから呼び出されたときに propagate メソッドによって呼び出されます。
unbounded_buffer::propagate_output_messages メソッド	message_PMessage をこの unbounded_buffer メッセージング ブロックに配置し、それをリンクされたすべてのターゲットに提供することを試みます。（をオーバーライド source_block::propagate_output_messages）。
unbounded_buffer::release_message メソッド	以前に行われたメッセージの予約を解放します。(source_block::release_message をオーバーライドします。)
unbounded_buffer::reserve_message メソッド	この unbounded_buffer メッセージング ブロックによって以前に提供されたメッセージを予約します。(source_block::reserve_message をオーバーライドします。)
unbounded_buffer::resume_propagation メソッド	予約が解放された後で反映を再開します。(source_block::resume_propagation をオーバーライドします。)
unbounded_buffer::send_message メソッド	ISource ブロックからこの unbounded_buffer メッセージング ブロックにメッセージを同期的に渡します。このメソッドは、ソース ブロックから呼び出されたときに send メソッドによって呼び出されます。
unbounded_buffer::supports_anonymous_source メソッド	supports_anonymous_source のメソッドをこのブロックにリンクされていないソースすることによって提供されたメッセージを受け入れることができることを示すためにオーバーライドします。（をオーバーライド ITarget::supports_anonymous_source）。

解説

詳細については、「非同期メッセージ ブロック」を参照してください。

継承階層

ISource

ITarget

source_block

propagator_block

unbounded_buffer

必要条件

ヘッダー: agents.h

名前空間: の同時実行

参照

関連項目

concurrency 名前空間

overwrite_buffer クラス

single_assignment クラス