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;
注解
处理器实现应替代此方法。