Share via

message_processor 类

  • 项目

message_processor 类是用于处理 message 对象的抽象基类。 不能保证消息的排序。

语法

template<class T>
class message_processor;

参数

T
此 message_processor 对象处理的消息中有效负载的数据类型。

成员

公共 Typedef

名称 描述
type T 的类型别名。

公共方法

名称 描述
async_send 在派生类中被替代时，以异步方式将消息放入块中。
sync_send 在派生类中被替代时，以同步方式将消息放入块中。
wait 在派生类中被替代时，等待所有异步操作完成。

受保护方法

名称 描述
process_incoming_message 在派生类中被替代时，将消息转接到块中。 每次添加新消息并发现队列为空时，调用一次。

继承层次结构

message_processor

要求

标头： agents.h

命名空间： 并发

async_send

在派生类中被替代时，以异步方式将消息放入块中。

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

参数

_Msg
要异步发送的 message 对象。

注解

处理器实现应替代此方法。

process_incoming_message

在派生类中被替代时，将消息转接到块中。 每次添加新消息并发现队列为空时，调用一次。

virtual void process_incoming_message() = 0;

备注

消息块实现应替代此方法。

sync_send

在派生类中被替代时，以同步方式将消息放入块中。

virtual void sync_send(_Inout_opt_ message<T>* _Msg) = 0;

参数

_Msg
要同步发送的 message 对象。

注解

处理器实现应替代此方法。

wait

在派生类中被替代时，等待所有异步操作完成。

virtual void wait() = 0;

注解

处理器实现应替代此方法。

另请参阅

并发命名空间
ordered_message_processor 类