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 オブジェクトを破棄します。 |
パブリック メソッド
名前 |
説明 |
|---|---|
メッセージを非同期的にキューに配置し、処理タスクがまだ実行されていなければ、開始します。(message_processor::async_send をオーバーライドします)。 |
|
適切なコールバック関数、スケジューラ、およびスケジュール グループを使用して、ordered_message_processor オブジェクトを初期化します。 |
|
ordered_message_processor::initialize_batched_processing メソッド |
Initialize バッチ処理されるメッセージ処理 |
メッセージを同期的にキューに配置し、処理タスクがまだ実行されていなければ、開始します。(message_processor::sync_send をオーバーライドします)。 |
|
ブロックを破棄する前にすべての非同期処理タスクが完了する時間を確保するためにメッセージ ブロックのデストラクター内で使用されるプロセッサに固有のスピン待機です。(message_processor::wait をオーバーライドします)。 |
プロテクト メソッド
名前 |
説明 |
|---|---|
非同期的に呼び出される処理関数です。 キューからメッセージを削除し、メッセージの処理を開始します。(message_processor::process_incoming_message をオーバーライドします)。 |
継承階層
ordered_message_processor
必要条件
ヘッダー: agents.h
名前空間: concurrency