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. |
| wait | 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