Partager via


ordered_message_processor, classe

Un ordered_message_processor est un message_processor qui permet aux blocs de messages de traiter les messages dans l'ordre dans lequel ils ont été reçus.

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

Paramètres

  • _Type
    Le type de charge utile des messages gérés par le processeur.

Membres

Typedefs publics

Nom

Description

type

Alias de type pour _Type.

Constructeurs publics

Nom

Description

ordered_message_processor::ordered_message_processor, constructeur

Construit un objet ordered_message_processor.

ordered_message_processor::~ordered_message_processor, destructeur

Détruit l'objet ordered_message_processor.

M&#233;thodes publiques

Nom

Description

ordered_message_processor::async_send, méthode

Place les messages en file d'attente et démarre une tâche de traitement de façon asynchrone, si cela n'a pas déjà été fait. (Substitue message_processor::async_send.)

ordered_message_processor::initialize, méthode

Initialise l'objet ordered_message_processor avec la fonction de rappel, le planificateur et le groupe de planification appropriés.

ordered_message_processor::initialize_batched_processing, méthode

Initialise le traitement des messages en lots

ordered_message_processor::sync_send, méthode

Met en file d'attente de façon synchrone des messages et démarre une tâche de traitement, si cela n'a pas déjà été fait. (Substitue message_processor::sync_send.)

ordered_message_processor::wait, méthode

Attente de rotation spécifique au processeur utilisée dans les destructeurs de blocs de messages pour s'assurer que toutes les tâches de traitement asynchrone ont le temps de finir avant la destruction du bloc. (Substitue message_processor::wait.)

Méthodes protégées

Nom

Description

ordered_message_processor::process_incoming_message, méthode

Fonction de traitement appelée de façon asynchrone. Il retire les messages de la file d'attente et commence à les traiter. (Substitue message_processor::process_incoming_message.)

Hiérarchie d'héritage

message_processor

ordered_message_processor

Configuration requise

En-tête : agents.h

Espace de noms : concurrency

Voir aussi

Référence

concurrency, espace de noms