Freigeben über


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

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

ordered_message_processor::async_send-Methode

Stellt asynchron Meldungen in die Warteschlange ein und startet eine Verarbeitungsaufgabe, wenn dies nicht bereits geschehen ist. (Überschreibt message_processor::async_send.)

ordered_message_processor::initialize-Methode

Initialisiert das ordered_message_processor-Objekt mit der entsprechenden Rückruffunktion, dem Planer und der Planungsgruppe.

ordered_message_processor::sync_send-Methode

Stellt synchron Meldungen in die Warteschlange ein und startet eine Verarbeitungsaufgabe, wenn dies nicht bereits geschehen ist. (Überschreibt message_processor::sync_send.)

ordered_message_processor::wait-Methode

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

ordered_message_processor::process_incoming_message-Methode

Die Verarbeitungsfunktion, die asynchron aufgerufen wird. Entfernt Meldungen aus der Warteschlange und verarbeitet sie. (Überschreibt message_processor::process_incoming_message.)

Vererbungshierarchie

message_processor

ordered_message_processor

Anforderungen

Header: agents.h

Namespace: Concurrency

Siehe auch

Referenz

Concurrency-Namespace