Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
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 |
Beschreibungen |
|---|---|
type |
Ein Typalias für _Type. |
Öffentliche Konstruktoren
Name |
Beschreibungen |
|---|---|
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 |
Beschreibungen |
|---|---|
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. |
|
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 |
Beschreibungen |
|---|---|
Die Verarbeitungsfunktion, die asynchron aufgerufen wird. Entfernt Meldungen aus der Warteschlange und verarbeitet sie. (Überschreibt message_processor::process_incoming_message.) |
Vererbungshierarchie
Anforderungen
Header: agents.h
Namespace: Concurrency