共用方式為


ordered_message_processor 類別

ordered_message_processormessage_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.)

繼承階層架構

message_processor

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();

另請參閱

concurrency 命名空間