Partager via


message_processor, classe

La classe message_processor est la classe de base abstraite pour le traitement des objets message. Aucune garantie n'existe sur l'ordre des messages.

Syntaxe

template<class T>
class message_processor;

Paramètres

T
Type de données de la charge utile dans les messages gérés par cet message_processor objet.

Membres

Typedefs publics

Nom Description
type Alias de type pour T.

Méthodes publiques

Nom Description
async_send En cas de substitution dans une classe dérivée, place les messages dans le bloc de manière asynchrone.
sync_send En cas de substitution dans une classe dérivée, place les messages dans le bloc de façon synchrone.
Attendre En cas de substitution dans une classe dérivée, attend que toutes les opérations asynchrones se terminent.

Méthodes protégées

Nom Description
process_incoming_message En cas de substitution dans une classe dérivée, effectue le traitement avant des messages dans le bloc. Appelée une fois chaque fois qu’un nouveau message est ajouté et que la file d’attente est trouvée vide.

Hiérarchie d'héritage

message_processor

Spécifications

En-tête : agents.h

Espace de noms : concurrency

async_send

En cas de substitution dans une classe dérivée, place les messages dans le bloc de manière asynchrone.

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

Paramètres

_Msg
Objet message à envoyer de façon asynchrone.

Notes

Les implémentations de processeur doivent remplacer cette méthode.

process_incoming_message

En cas de substitution dans une classe dérivée, effectue le traitement avant des messages dans le bloc. Appelée une fois chaque fois qu’un nouveau message est ajouté et que la file d’attente est trouvée vide.

virtual void process_incoming_message() = 0;

Notes

Les implémentations de bloc de message doivent remplacer cette méthode.

sync_send

En cas de substitution dans une classe dérivée, place les messages dans le bloc de façon synchrone.

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

Paramètres

_Msg
Objet message à envoyer de façon synchrone.

Notes

Les implémentations de processeur doivent remplacer cette méthode.

wait

En cas de substitution dans une classe dérivée, attend que toutes les opérations asynchrones se terminent.

virtual void wait() = 0;

Notes

Les implémentations de processeur doivent remplacer cette méthode.

Voir aussi

accès concurrentiel Namespace
ordered_message_processor, classe