Classe ordered_message_processor

Articolo
03/05/2013

Un ordered_message_processor è un message_processor che consente ai blocchi del messaggio di elaborare messaggi nell'ordine in cui vengono ricevuti.

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

Parametri

_Type
Tipo di payload dei messaggi gestiti dal processore.

Membri

Typedef pubblici

Nome	Descrizione
type	Tipo alias per _Type.

Costruttori pubblici

Nome	Descrizione
Costruttore ordered_message_processor::ordered_message_processor	Costruisce un oggetto ordered_message_processor.
Distruttore ordered_message_processor::~ordered_message_processor	Elimina l'oggetto ordered_message_processor.

Metodi pubblici

Nome	Descrizione
Metodo ordered_message_processor::async_send	Consente di mettere in coda in modo asincrono i messaggi e avviare un'attività di elaborazione, se questa non è stata già eseguita.(Esegue l'override di message_processor::async_send.)
Metodo ordered_message_processor::initialize	Inizializza l'oggetto ordered_message_processor con la funzione di callback, l'utilità di pianificazione e il gruppo di pianificazione appropriati.
Metodo ordered_message_processor::initialize_batched_processing	Elaborazione dei messaggi in batch Initialize
Metodo ordered_message_processor::sync_send	Consente di mettere in coda in modo sincrono i messaggi e avviare un'attività di elaborazione, se questa non è stata già eseguita.(Esegue l'override di message_processor::sync_send.)
Metodo ordered_message_processor::wait	Un'attesa della rotazione specifica del processore utilizzata in distruttori di blocchi di messaggio per assicurarsi che tutte le attività dell'elaborazione asincrona dispongano del tempo per il completamento prima di distruggere il blocco.(Esegue l'override di message_processor::wait.)

Metodi protetti

Nome	Descrizione
Metodo ordered_message_processor::process_incoming_message	Funzione di elaborazione chiamata in modo asincrono.Rimuove messaggi dalla coda e comincia ad elaborarli.(Esegue l'override di message_processor::process_incoming_message.)

Gerarchia di ereditarietà

message_processor

ordered_message_processor

Requisiti

Header: agents.h

Concorrenza diSpazio dei nomi:

Vedere anche

Riferimenti

Spazio dei nomi concurrency

Condividi tramite