Compartilhar via


Classe ordered_message_processor

ordered_message_processor é message_processor que permite que os blocos de mensagem processar mensagens na ordem em que foram recebidas.

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

Parâmetros

  • _Type
    O tipo de carga útil de mensagens tratadas por processador.

Membros

Typedefs Públicas

Nome

Descrição

type

Um alias de tipo para _Type.

Construtores Públicos

Nome

Descrição

Construtor ordered_message_processor::ordered_message_processor

Constrói um objeto ordered_message_processor.

Destruidor ordered_message_processor::~ordered_message_processor

Destrói o objeto ordered_message_processor.

Métodos Públicos

Nome

Descrição

Método ordered_message_processor::async_send

As linhas de forma assíncrona acima mensagens e inicia uma tarefa de processamento, se isso já não tiver sido feita. (Substitui message_processor::async_send.)

Método ordered_message_processor::initialize

Inicializa o objeto de ordered_message_processor com a função de retorno de chamada, o agendador e o grupo apropriadas da agenda.

Método ordered_message_processor::initialize_batched_processing

Inicializar processamento em lotes o processamento de mensagem

Método ordered_message_processor::sync_send

Enfileira mensagens de forma síncrona acima e inicia uma tarefa de processamento, se isso já não tiver sido feita. (Substitui message_processor::sync_send.)

Método ordered_message_processor::wait

Uma espera de processamento específica de rotação usada em destruidores de blocos de mensagem para garantir que todas as tarefas de processamento assíncrono têm tempo para ser concluída antes de destruir o bloco. (Substitui message_processor::wait.)

Métodos Protegidos

Nome

Descrição

Método ordered_message_processor::process_incoming_message

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

Hierarquia de Herança

message_processor

ordered_message_processor

Requisitos

Cabeçalho: agents.h

Namespace: simultaneidade

Consulte também

Referência

Namespace Concurrency