Třída overwrite_buffer

Blok overwrite_buffer zasílání zpráv je multi-target, multi-source, uspořádaný propagator_block schopný uložit jednu zprávu najednou. Nové zprávy přepíší dříve uchovávané zprávy.

Syntaxe

template<class T>
class overwrite_buffer : public propagator_block<multi_link_registry<ITarget<T>>, multi_link_registry<ISource<T>>>;

Parametry

T
Typ datové části zpráv uložených a šířených vyrovnávací pamětí.

Členové

Veřejné konstruktory

Jméno	popis
overwrite_buffer	Přetíženo. overwrite_buffer Vytvoří blok zasílání zpráv.
~overwrite_buffer Destruktor	overwrite_buffer Zničí blok zasílání zpráv.

Veřejné metody

Jméno	popis
has_value	Zkontroluje, jestli tento overwrite_buffer blok zasílání zpráv ještě má hodnotu.
value	Získá odkaz na aktuální datovou část zprávy, která je uložena overwrite_buffer v bloku zasílání zpráv.

Chráněné metody

Jméno	popis
accept_message	Přijímá zprávu, která byla nabízena tímto overwrite_buffer blokem zasílání zpráv a vrací kopii zprávy volajícímu.
consume_message	Využívá dříve nabízenou zprávu blokem overwrite_buffer zasílání zpráv a vyhrazenou cílem a vrací kopii zprávy volajícímu.
link_target_notification	Zpětné volání, které upozorní, že byl nový cíl propojen s tímto overwrite_buffer blokem zasílání zpráv.
propagate_message	Asynchronně předává zprávu z ISource bloku do tohoto overwrite_buffer bloku zasílání zpráv. Vyvolá se metodou propagate při zavolání zdrojovým blokem.
propagate_to_any_targets	message _PMessage Umístí do tohoto overwrite_buffer bloku zasílání zpráv a nabídne ho všem propojeným cílům.
release_message	Uvolní předchozí rezervaci zpráv. (Přepsání source_block::release_message.)
reserve_message	Zarezervuje dříve nabízenou zprávu v tomto overwrite_buffer bloku zasílání zpráv. (Přepsání source_block::reserve_message.)
resume_propagation	Po vydání rezervace se obnoví šíření. (Přepsání source_block::resume_propagation.)
send_message	Synchronně předává zprávu z ISource bloku do tohoto overwrite_buffer bloku zasílání zpráv. Vyvolá se metodou send při zavolání zdrojovým blokem.
supports_anonymous_source	Přepíše metodu supports_anonymous_source tak, aby označovala, že tento blok může přijímat zprávy nabízené zdrojem, který není propojený. (Přepsání ITarget::supports_anonymous_source.)

Poznámky

Blok overwrite_buffer zasílání zpráv rozšíří kopie uložené zprávy do každého z cílů.

Další informace naleznete v tématu Asynchronní bloky zpráv.

Hierarchie dědičnosti

ISource

ITarget

source_block

propagator_block

overwrite_buffer

Požadavky

Hlavička: agents.h

Obor názvů: souběžnost

accept_message

Přijímá zprávu, která byla nabízena tímto overwrite_buffer blokem zasílání zpráv a vrací kopii zprávy volajícímu.

virtual message<T>* accept_message(runtime_object_identity _MsgId);

Parametry

_MsgId
message Nabízený runtime_object_identity objekt.

Vrácená hodnota

Ukazatel na message objekt, ke kterému má volající nyní vlastnictví.

Poznámky

Blok overwrite_buffer zasílání zpráv vrátí kopie zprávy do svých cílů a nepřenese vlastnictví aktuálně uchovávané zprávy.

consume_message

Využívá dříve nabízenou zprávu blokem overwrite_buffer zasílání zpráv a vyhrazenou cílem a vrací kopii zprávy volajícímu.

virtual message<T>* consume_message(runtime_object_identity _MsgId);

Parametry

_MsgId
Objekt runtime_object_identity , který message se spotřebovává.

Vrácená hodnota

Ukazatel na message objekt, ke kterému má volající nyní vlastnictví.

Poznámky

acceptPodobá se , ale vždy předchází volání reserve.

has_value

Zkontroluje, jestli tento overwrite_buffer blok zasílání zpráv ještě má hodnotu.

bool has_value() const;

Vrácená hodnota

true pokud blok obdržel hodnotu, false jinak.

link_target_notification

Zpětné volání, které upozorní, že byl nový cíl propojen s tímto overwrite_buffer blokem zasílání zpráv.

virtual void link_target_notification(_Inout_ ITarget<T>* _PTarget);

Parametry

_PTarget
Ukazatel na nově propojený cíl.

~overwrite_buffer

overwrite_buffer Zničí blok zasílání zpráv.

~overwrite_buffer();

overwrite_buffer

overwrite_buffer Vytvoří blok zasílání zpráv.

overwrite_buffer();

overwrite_buffer(
    filter_method const& _Filter);

overwrite_buffer(
    Scheduler& _PScheduler);

overwrite_buffer(
    Scheduler& _PScheduler,
    filter_method const& _Filter);

overwrite_buffer(
    ScheduleGroup& _PScheduleGroup);

overwrite_buffer(
    ScheduleGroup& _PScheduleGroup,
    filter_method const& _Filter);

Parametry

_Filtr
Funkce filtru, která určuje, jestli mají být přijaté zprávy.

_PScheduler
Objekt Scheduler , ve kterém je naplánována úloha šíření bloku overwrite_buffer zasílání zpráv.

_PScheduleGroup
Objekt ScheduleGroup , ve kterém je naplánována úloha šíření bloku overwrite_buffer zasílání zpráv. Použitý Scheduler objekt je odvozen ze skupiny plánů.

Poznámky

Modul runtime používá výchozí plánovač, pokud nezadáte _PScheduler parametry._PScheduleGroup

Typ filter_method je functor s podpisem bool (T const &) , který je vyvolán tímto overwrite_buffer blokem zasílání zpráv, aby určil, zda má přijmout nabízenou zprávu.

propagate_message

Asynchronně předává zprávu z ISource bloku do tohoto overwrite_buffer bloku zasílání zpráv. Vyvolá se metodou propagate při zavolání zdrojovým blokem.

virtual message_status propagate_message(
    _Inout_ message<T>* _PMessage,
    _Inout_ ISource<T>* _PSource);

Parametry

_PMessage
Ukazatel na message objekt.

_PSource
Ukazatel na zdrojový blok nabízející zprávu.

Vrácená hodnota

Message_status označení toho, co se cíl rozhodl se zprávou udělat.

propagate_to_any_targets

message _PMessage Umístí do tohoto overwrite_buffer bloku zasílání zpráv a nabídne ho všem propojeným cílům.

virtual void propagate_to_any_targets(_Inout_ message<T>* _PMessage);

Parametry

_PMessage
Ukazatel na message objekt, overwrite_buffer který převzal vlastnictví.

Poznámky

Tato metoda přepíše aktuální zprávu v overwrite_buffer nově přijaté zprávě _PMessage.

send_message

Synchronně předává zprávu z ISource bloku do tohoto overwrite_buffer bloku zasílání zpráv. Vyvolá se metodou send při zavolání zdrojovým blokem.

virtual message_status send_message(
    _Inout_ message<T>* _PMessage,
    _Inout_ ISource<T>* _PSource);

Parametry

_PMessage
Ukazatel na message objekt.

_PSource
Ukazatel na zdrojový blok nabízející zprávu.

Vrácená hodnota

Message_status označení toho, co se cíl rozhodl se zprávou udělat.

supports_anonymous_source

Přepíše metodu supports_anonymous_source tak, aby označovala, že tento blok může přijímat zprávy nabízené zdrojem, který není propojený.

virtual bool supports_anonymous_source();

Vrácená hodnota

true vzhledem k tomu, že blok odloží nabízené zprávy.

release_message

Uvolní předchozí rezervaci zpráv.

virtual void release_message(runtime_object_identity _MsgId);

Parametry

_MsgId
Uvolnění runtime_object_identity objektu message .

reserve_message

Zarezervuje dříve nabízenou zprávu v tomto overwrite_buffer bloku zasílání zpráv.

virtual bool reserve_message(runtime_object_identity _MsgId);

Parametry

_MsgId
Objekt runtime_object_identity , který message je rezervován.

Vrácená hodnota

true pokud byla zpráva úspěšně rezervována, false jinak.

Poznámky

Po reserve zavolání, pokud se vrátí true, buď consume nebo release musí být volána k převzetí nebo uvolnění vlastnictví zprávy.

resume_propagation

Po vydání rezervace se obnoví šíření.

virtual void resume_propagation();

hodnotu

Získá odkaz na aktuální datovou část zprávy, která je uložena overwrite_buffer v bloku zasílání zpráv.

T value();

Vrácená hodnota

Datová část aktuálně uložené zprávy.

Poznámky

Hodnota uložená v této overwrite_buffer metodě se může změnit okamžitě po vrácení této metody. Tato metoda počká, dokud zpráva nedorazí, pokud není v současné době uložena žádná zpráva .overwrite_buffer

Viz také

concurrency – obor názvů
unbounded_buffer – třída
single_assignment – třída