ordered_message_processor 類別
ordered_message_processor
是 message_processor
,可讓訊息區塊按照接收順序處理訊息。
語法
template<class T>
class ordered_message_processor : public message_processor<T>;
參數
T
處理器所處理之訊息的承載類型。
成員
公用 Typedefs
名稱 | 描述 |
---|---|
type |
的類型 T 別名。 |
公用建構函式
名稱 | 描述 |
---|---|
ordered_message_processor | 建構 ordered_message_processor 物件。 |
~ordered_message_processor解構函式 | ordered_message_processor 終結物件。 |
公用方法
名稱 | 描述 |
---|---|
async_send | 如果尚未完成,請以異步方式將訊息排入佇列,並啟動處理工作。 (覆寫 message_processor::async_send. |
初始化 | ordered_message_processor 使用適當的回呼函式、排程器和排程群組,初始化物件。 |
initialize_batched_processing | 初始化批次訊息處理 |
sync_send | 如果尚未完成,同步佇列訊息並啟動處理工作。 (覆寫 message_processor::sync_send. |
等 | 訊息區塊解構函式中使用的處理器特定微調等候,以確保所有異步處理工作在終結區塊之前都必須有時間完成。 (覆寫 message_processor::wait. |
受保護的方法
名稱 | 描述 |
---|---|
process_incoming_message | 異步呼叫的處理函式。 它會清除佇列訊息,並開始處理訊息。 (覆寫 message_processor::p rocess_incoming_message.) |
繼承階層架構
ordered_message_processor
需求
標頭: agents.h
命名空間: concurrency
async_send
如果尚未完成,請以異步方式將訊息排入佇列,並啟動處理工作。
virtual void async_send(_Inout_opt_ message<T>* _Msg);
參數
_味精
訊息的指標。
initialize
ordered_message_processor
使用適當的回呼函式、排程器和排程群組,初始化物件。
void initialize(
_Inout_opt_ Scheduler* _PScheduler,
_Inout_opt_ ScheduleGroup* _PScheduleGroup,
_Handler_method const& _Handler);
參數
_PScheduler
要用於排程輕量工作之排程器的指標。
_PScheduleGroup
要用於排程羽量工作之排程群組的指標。
_處理器
在回呼期間叫用的處理程式函式。
initialize_batched_processing
初始化批次訊息處理
virtual void initialize_batched_processing(
_Handler_method const& _Processor,
_Propagator_method const& _Propagator);
參數
_處理器
回呼期間叫用的處理器函式。
_Propagator
回呼期間叫用的傳播器函式。
ordered_message_processor
建構 ordered_message_processor
物件。
ordered_message_processor();
備註
在呼叫 函式之前initialize
,這ordered_message_processor
不會排程異步或同步處理程式。
~ordered_message_processor
ordered_message_processor
終結物件。
virtual ~ordered_message_processor();
備註
先等候所有未處理的異步操作,再終結處理器。
process_incoming_message
異步呼叫的處理函式。 它會清除佇列訊息,並開始處理訊息。
virtual void process_incoming_message();
sync_send
如果尚未完成,同步佇列訊息並啟動處理工作。
virtual void sync_send(_Inout_opt_ message<T>* _Msg);
參數
_味精
訊息的指標。
wait
訊息區塊解構函式中使用的處理器特定微調等候,以確保所有異步處理工作在終結區塊之前都必須有時間完成。
virtual void wait();