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 .）

繼承階層架構

message_processor

ordered_message_processor

需求

標頭： agents.h

命名空間： concurrency

async_send

如果尚未完成，請以非同步方式將訊息排入佇列，並啟動處理工作。

virtual void async_send(_Inout_opt_ message<T>* _Msg);

參數

_味精
訊息的指標。

初始 化

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 命名空間