Classe ordered_message_processor

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

Oggetto di descrizione

type

Tipo alias per _Type.

Costruttori pubblici

Nome

Oggetto di 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

Oggetto di 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::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

Oggetto di 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

Spazio dei nomi: Concurrency

Vedere anche

Riferimenti

Spazio dei nomi Concurrency