ordered_message_processor-Klasse
Ein ordered_message_processor ist ein message_processor, mit dem Meldungsblöcke Meldungen in der Reihenfolge verarbeiten können, in der sie empfangen wurden.
template<
class _Type
>
class ordered_message_processor : public message_processor<_Type>;
Parameter
- _Type
Der Nutzlasttyp von durch den Prozessor behandelten Meldungen.
Member
Öffentliche Typedefs
Name |
Beschreibung |
|---|---|
type |
Ein Typalias für _Type. |
Öffentliche Konstruktoren
Name |
Beschreibung |
|---|---|
ordered_message_processor::ordered_message_processor-Konstruktor |
Erstellt ein ordered_message_processor-Objekt. |
ordered_message_processor::~ordered_message_processor-Destruktor |
Zerstört das ordered_message_processor-Objekt. |
Öffentliche Methoden
Name |
Beschreibung |
|---|---|
Stellt asynchron Meldungen in die Warteschlange ein und startet eine Verarbeitungsaufgabe, wenn dies nicht bereits geschehen ist. (Überschreibt message_processor::async_send.) |
|
Initialisiert das ordered_message_processor-Objekt mit der entsprechenden Rückruffunktion, dem Planer und der Planungsgruppe. |
|
ordered_message_processor::initialize_batched_processing-Methode |
Initialize verarbeitete Meldungsverarbeitung von bei |
Stellt synchron Meldungen in die Warteschlange ein und startet eine Verarbeitungsaufgabe, wenn dies nicht bereits geschehen ist. (Überschreibt message_processor::sync_send.) |
|
Ein prozessorspezifischer Spin-Wait, der in Destruktoren von Meldungsblöcken verwendet wird, um sicherzustellen, dass alle asynchronen Verarbeitungsaufgaben genügend Zeit zum Beenden erhalten, bevor der Block zerstört wird. (Überschreibt message_processor::wait.) |
Geschützte Methoden
Name |
Beschreibung |
|---|---|
Die Verarbeitungsfunktion, die asynchron aufgerufen wird. Entfernt Meldungen aus der Warteschlange und verarbeitet sie. (Überschreibt message_processor::process_incoming_message.) |
Vererbungshierarchie
ordered_message_processor
Anforderungen
Header: agents.h
Namespace: Parallelität