Classe overwrite_buffer
Un blocco della messaggistica overwrite_buffer è un propagator_block multi-origine a destinazione singola, in grado di archiviare un unico messaggio alla volta. I nuovi messaggi sovrascrivono i precedenti.
Sintassi
template<class T>
class overwrite_buffer : public propagator_block<multi_link_registry<ITarget<T>>, multi_link_registry<ISource<T>>>;
Parametri
T
Tipo di payload dei messaggi archiviati e propagati dal buffer.
Membri
Costruttori pubblici
| Nome | Descrizione |
|---|---|
| Overwrite_buffer | Con overload. Costruisce un overwrite_buffer blocco di messaggistica. |
| Distruttore ~overwrite_buffer | Elimina definitivamente il overwrite_buffer blocco di messaggistica. |
Metodi pubblici
| Nome | Descrizione |
|---|---|
| has_value | Controlla se il overwrite_buffer blocco di messaggistica ha ancora un valore. |
| value | Ottiene un riferimento al payload corrente del messaggio archiviato nel overwrite_buffer blocco di messaggistica. |
Metodi protetti
| Nome | Descrizione |
|---|---|
| accept_message | Accetta un messaggio offerto da questo overwrite_buffer blocco di messaggistica, restituendo una copia del messaggio al chiamante. |
| consume_message | Utilizza un messaggio offerto in precedenza dal overwrite_buffer blocco di messaggistica e riservato dalla destinazione, restituendo una copia del messaggio al chiamante. |
| link_target_notification | Callback che notifica che una nuova destinazione è stata collegata a questo overwrite_buffer blocco di messaggistica. |
| propagate_message | Passa in modo asincrono un messaggio da un ISource blocco a questo overwrite_buffer blocco di messaggistica. Viene richiamato dal propagate metodo , quando viene chiamato da un blocco di origine. |
| propagate_to_any_targets | Inserisce in message _PMessage questo overwrite_buffer blocco di messaggistica e lo offre a tutte le destinazioni collegate. |
| release_message | Rilascia una prenotazione di messaggi precedente. (Esegue l'override di source_block::release_message. |
| reserve_message | Riserva un messaggio offerto in precedenza da questo overwrite_buffer blocco di messaggistica. Esegue l'override di source_block::reserve_message. |
| resume_propagation | Riprende la propagazione dopo il rilascio di una prenotazione. (Esegue l'override di source_block::resume_propagation. |
| send_message | Passa in modo sincrono un messaggio da un ISource blocco a questo overwrite_buffer blocco di messaggistica. Viene richiamato dal send metodo , quando viene chiamato da un blocco di origine. |
| supports_anonymous_source | Esegue l'override del metodo supports_anonymous_source per indicare che questo blocco può accettare messaggi offerti da un'origine non collegata. (sostituzioni )ITarget::supports_anonymous_source.) |
Osservazioni:
Un overwrite_buffer blocco di messaggistica propaga copie del messaggio archiviato a ognuna delle destinazioni.
Per altre informazioni, vedere Blocchi di messaggi asincroni.
Gerarchia di ereditarietà
overwrite_buffer
Requisiti
Intestazione: agents.h
Spazio dei nomi: Concurrency
accept_message
Accetta un messaggio offerto da questo overwrite_buffer blocco di messaggistica, restituendo una copia del messaggio al chiamante.
virtual message<T>* accept_message(runtime_object_identity _MsgId);
Parametri
_Msgid
Oggetto runtime_object_identity dell'oggetto offerto message .
Valore restituito
Puntatore all'oggetto message di cui il chiamante ha ora la proprietà.
Osservazioni:
Il overwrite_buffer blocco di messaggistica restituisce copie del messaggio nelle destinazioni, anziché trasferire la proprietà del messaggio attualmente mantenuto.
consume_message
Utilizza un messaggio offerto in precedenza dal overwrite_buffer blocco di messaggistica e riservato dalla destinazione, restituendo una copia del messaggio al chiamante.
virtual message<T>* consume_message(runtime_object_identity _MsgId);
Parametri
_Msgid
Oggetto runtime_object_identity dell'oggetto message utilizzato.
Valore restituito
Puntatore all'oggetto message di cui il chiamante ha ora la proprietà.
Osservazioni:
Simile a accept, ma è sempre preceduto da una chiamata a reserve.
has_value
Controlla se il overwrite_buffer blocco di messaggistica ha ancora un valore.
bool has_value() const;
Valore restituito
true se il blocco ha ricevuto un valore, false in caso contrario.
link_target_notification
Callback che notifica che una nuova destinazione è stata collegata a questo overwrite_buffer blocco di messaggistica.
virtual void link_target_notification(_Inout_ ITarget<T>* _PTarget);
Parametri
_PTarget
Puntatore alla destinazione appena collegata.
~Overwrite_buffer
Elimina definitivamente il overwrite_buffer blocco di messaggistica.
~overwrite_buffer();
Overwrite_buffer
Costruisce un overwrite_buffer blocco di messaggistica.
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);
Parametri
_Filtro
Funzione di filtro che determina se i messaggi offerti devono essere accettati.
_PScheduler
Oggetto Scheduler all'interno del quale è pianificata l'attività di propagazione per il blocco della messaggistica overwrite_buffer .
_PScheduleGroup
Oggetto ScheduleGroup all'interno del quale è pianificata l'attività di propagazione per il blocco della messaggistica overwrite_buffer . L'oggetto Scheduler usato è previsto dal gruppo di pianificazione.
Osservazioni:
Se non si specificano i parametri _PScheduler o _PScheduleGroup , il runtime usa l'utilità di pianificazione predefinita.
Il tipo filter_method è un funtore con firma bool (T const &) che viene richiamato da questo overwrite_buffer blocco di messaggistica per determinare se deve accettare o meno un messaggio offerto.
propagate_message
Passa in modo asincrono un messaggio da un ISource blocco a questo overwrite_buffer blocco di messaggistica. Viene richiamato dal propagate metodo , quando viene chiamato da un blocco di origine.
virtual message_status propagate_message(
_Inout_ message<T>* _PMessage,
_Inout_ ISource<T>* _PSource);
Parametri
_PMessage
Puntatore all'oggetto message.
_PSource
Puntatore al blocco di origine che offre il messaggio.
Valore restituito
Un message_status'indicazione di ciò che la destinazione ha deciso di fare con il messaggio.
propagate_to_any_targets
Inserisce in message _PMessage questo overwrite_buffer blocco di messaggistica e lo offre a tutte le destinazioni collegate.
virtual void propagate_to_any_targets(_Inout_ message<T>* _PMessage);
Parametri
_PMessage
Puntatore a un message oggetto di cui è overwrite_buffer stata acquisita la proprietà.
Osservazioni:
Questo metodo sovrascrive il messaggio corrente in overwrite_buffer con il messaggio _PMessageappena accettato.
send_message
Passa in modo sincrono un messaggio da un ISource blocco a questo overwrite_buffer blocco di messaggistica. Viene richiamato dal send metodo , quando viene chiamato da un blocco di origine.
virtual message_status send_message(
_Inout_ message<T>* _PMessage,
_Inout_ ISource<T>* _PSource);
Parametri
_PMessage
Puntatore all'oggetto message.
_PSource
Puntatore al blocco di origine che offre il messaggio.
Valore restituito
Un message_status'indicazione di ciò che la destinazione ha deciso di fare con il messaggio.
supports_anonymous_source
Esegue l'override del metodo supports_anonymous_source per indicare che questo blocco può accettare messaggi offerti da un'origine non collegata.
virtual bool supports_anonymous_source();
Valore restituito
true poiché il blocco non posticipa i messaggi offerti.
release_message
Rilascia una prenotazione di messaggi precedente.
virtual void release_message(runtime_object_identity _MsgId);
Parametri
_Msgid
Oggetto runtime_object_identity dell'oggetto message da rilasciare.
reserve_message
Riserva un messaggio offerto in precedenza da questo overwrite_buffer blocco di messaggistica.
virtual bool reserve_message(runtime_object_identity _MsgId);
Parametri
_Msgid
Oggetto runtime_object_identity dell'oggetto message riservato.
Valore restituito
true se il messaggio è stato riservato correttamente, false in caso contrario.
Osservazioni:
Dopo reserve la chiamata, se restituisce true, consume o release deve essere chiamato per accettare o rilasciare la proprietà del messaggio.
resume_propagation
Riprende la propagazione dopo il rilascio di una prenotazione.
virtual void resume_propagation();
value
Ottiene un riferimento al payload corrente del messaggio archiviato nel overwrite_buffer blocco di messaggistica.
T value();
Valore restituito
Payload del messaggio attualmente archiviato.
Osservazioni:
Il valore archiviato in overwrite_buffer può cambiare immediatamente dopo che questo metodo viene restituito. Questo metodo attenderà l'arrivo di un messaggio se non è attualmente archiviato alcun messaggio in overwrite_buffer.
Vedi anche
Spazio dei nomi concurrency
Classe unbounded_buffer
Classe single_assignment
Commenti e suggerimenti
Presto disponibile: Nel corso del 2024 verranno gradualmente disattivati i problemi di GitHub come meccanismo di feedback per il contenuto e ciò verrà sostituito con un nuovo sistema di feedback. Per altre informazioni, vedere https://aka.ms/ContentUserFeedback.
Invia e visualizza il feedback per