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
| Název | 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
| Název | 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
| Název | 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
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.
Návratová 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á.
Návratová 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;
Návratová 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.
Návratová 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.
Návratová 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();
Návratová 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.
Návratová 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();
hodnota
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();
Návratová 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