ordered_message_processor 클래스
ordered_message_processor는 메시지 블록이 받은 순서대로 메시지를 처리할 수 있는 message_processor입니다.
template<
class _Type
>
class ordered_message_processor : public message_processor<_Type>;
매개 변수
- _Type
프로세서에 의해 처리되는 메시지의 페이로드 형식입니다.
멤버
공용 Typedefs
Name |
설명 |
---|---|
type |
_Type에 대한 형식의 별칭입니다. |
Public 생성자
Name |
설명 |
---|---|
ordered_message_processor 개체를 생성합니다. |
|
ordered_message_processor 개체를 소멸시킵니다. |
Public 메서드
Name |
설명 |
---|---|
아직 수행되지 않은 경우 비동기적으로 메시지를 큐에 대기시키고 처리 작업을 시작합니다. (message_processor::async_send를 재정의합니다.) |
|
적절한 콜백 함수, 스케줄러 및 일정 그룹으로 ordered_message_processor 개체를 초기화합니다. |
|
동기적으로 메시지를 큐에 대기시키고 아직 시작하지 않은 경우 처리 작업을 시작합니다. (message_processor::sync_send를 재정의합니다.) |
|
메시지 블록의 소멸자에 사용된 프로세서별 스핀 대기는 블록 소멸 전에 모든 비동기 처리 작업이 완료될 시간이 있는지 확인합니다. (message_processor::wait를 재정의합니다.) |
Protected 메서드
Name |
설명 |
---|---|
비동기적으로 호출되는 처리 함수입니다. 메시지를 큐에서 제거하고 처리를 시작합니다. (message_processor::process_incoming_message를 재정의합니다.) |
상속 계층 구조
요구 사항
헤더: agents.h
네임스페이스: 동시성