Classe ordered_message_processor

Uma ordered_message_processor é um message_processor que permite que blocos de mensagens processem mensagens na ordem em que foram recebidas.

Sintaxe

template<class T>
class ordered_message_processor : public message_processor<T>;

Parâmetros

T
O tipo de carga de mensagens manipuladas pelo processador.

Membros

Typedefs públicos

Nome	Descrição
type	Um alias de tipo para T.

Construtores públicos

Nome	Descrição
ordered_message_processor	Constrói um objeto ordered_message_processor.
Destruidor ~ordered_message_processor	Destrói o objeto ordered_message_processor.

Métodos públicos

Nome	Descrição
async_send	Enfileira as mensagens de forma assíncrona e inicia uma tarefa de processamento se isso ainda não tiver sido feito. (Substitui message_processor::async_send.)
initialize	Inicializa o objeto ordered_message_processor com a função de retorno de chamada, o agendador e o grupo agendado apropriados.
initialize_batched_processing	Inicializa o processamento de mensagens em lote
sync_send	Enfileira as mensagens de forma síncrona e inicia uma tarefa de processamento se isso ainda não tiver sido feito. (Substitui message_processor::sync_send.)
wait	Essa espera de rotação específica do propagador é usada em destruidores de blocos de mensagem para garantir que todas as propagações assíncronas tenham tempo para serem concluídas antes da destruição do bloco. (Substitui message_processor::wait.)

Métodos protegidos

Nome	Descrição
process_incoming_message	A função de processamento que é chamada de forma assíncrona. Ela remove mensagens da fila e começa a processá-las. (Substitui message_processor::process_incoming_message.)

Hierarquia de herança

message_processor

ordered_message_processor

Requisitos

Cabeçalho: agents.h

Namespace: concurrency

async_send

Enfileira as mensagens de forma assíncrona e inicia uma tarefa de processamento se isso ainda não tiver sido feito.

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

Parâmetros

_Msg
Um ponteiro para uma mensagem.

Initialize

Inicializa o objeto ordered_message_processor com a função de retorno de chamada, o agendador e o grupo agendado apropriados.

void initialize(
    _Inout_opt_ Scheduler* _PScheduler,
    _Inout_opt_ ScheduleGroup* _PScheduleGroup,
    _Handler_method const& _Handler);

Parâmetros

_PScheduler
Um ponteiro para o agendador a ser usado para agendar tarefas leves.

_PScheduleGroup
Um ponteiro para o grupo agendado a ser usado para agendar tarefas leves.

_Handler
O functor do manipulador invocado durante o retorno de chamada.

initialize_batched_processing

Inicializa o processamento de mensagens em lote

virtual void initialize_batched_processing(
    _Handler_method const& _Processor,
    _Propagator_method const& _Propagator);

Parâmetros

_Processor
O functor do processador invocado durante o retorno de chamada.

_Propagator
O functor do propagador invocado durante o retorno de chamada.

ordered_message_processor

Constrói um objeto ordered_message_processor.

ordered_message_processor();

Comentários

Esse ordered_message_processor não agendará manipuladores assíncronos ou síncronos enquanto a função initialize não for chamada.

~ordered_message_processor

Destrói o objeto ordered_message_processor.

virtual ~ordered_message_processor();

Comentários

Aguarda todas as operações assíncronas pendentes antes de destruir o processador.

process_incoming_message

A função de processamento que é chamada de forma assíncrona. Ela remove mensagens da fila e começa a processá-las.

virtual void process_incoming_message();

sync_send

Enfileira as mensagens de forma síncrona e inicia uma tarefa de processamento se isso ainda não tiver sido feito.

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

Parâmetros

_Msg
Um ponteiro para uma mensagem.

wait

Essa espera de rotação específica do propagador é usada em destruidores de blocos de mensagem para garantir que todas as propagações assíncronas tenham tempo para serem concluídas antes da destruição do bloco.

virtual void wait();

Confira também

Namespace de simultaneidade