ordered_message_processor クラス

ordered_message_processor は、メッセージ ブロックがメッセージを受け取った順序で処理できるようにする message_processor です。

template<
   class _Type
>
class ordered_message_processor : public message_processor<_Type>;

パラメーター

  • _Type
    プロセッサで処理されるメッセージのペイロード型。

メンバー

パブリック typedef

名前

説明

type

_Type の型のエイリアス。

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

名前

説明

ordered_message_processor::ordered_message_processor コンストラクター

ordered_message_processor オブジェクトを構築します。

ordered_message_processor::~ordered_message_processor デストラクター

ordered_message_processor オブジェクトを破棄します。

パブリック メソッド

名前

説明

ordered_message_processor::async_send メソッド

メッセージを非同期的にキューに配置し、処理タスクがまだ実行されていなければ、開始します。 (message_processor::async_send をオーバーライドします)。

ordered_message_processor::initialize メソッド

適切なコールバック関数、スケジューラ、およびスケジュール グループを使用して、ordered_message_processor オブジェクトを初期化します。

ordered_message_processor::sync_send メソッド

メッセージを同期的にキューに配置し、処理タスクを開始します (実行していない場合)。 (message_processor::sync_send をオーバーライドします)。

ordered_message_processor::wait メソッド

ブロックを破棄する前にすべての非同期処理タスクが完了する時間を確保するためにメッセージ ブロックのデストラクター内で使用されるプロセッサに固有のスピン待機です。 (message_processor::wait をオーバーライドします)。

プロテクト メソッド

名前

説明

ordered_message_processor::process_incoming_message メソッド

非同期的に呼び出される処理関数です。 キューからメッセージを削除し、メッセージの処理を開始します。 (message_processor::process_incoming_message をオーバーライドします)。

継承階層

message_processor

ordered_message_processor

必要条件

ヘッダー: agents.h

名前空間: Concurrency

参照

参照

Concurrency 名前空間