Classe OverwriteBuffer

Un blocco di messaggistica overwrite_buffer è un elemento multi-destinazione, multi-origine, ordinato propagator_block 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

Metodi pubblici

Metodi protetti

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à

ISource

ITarget

source_block

propagator_block

overwrite_buffer

Requisiti

Intestazione: agents.h

Spazio dei nomi: Concurrency

accetta_messaggio

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
L'oggetto runtime_object_identity dell'offerta 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 ai suoi destinatari, anziché trasferire la proprietà del messaggio attualmente trattenuto.

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
Il runtime_object_identity dell'oggetto message che viene consumato.

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.

ha_valore

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.

notifica_destinazione_link

Callback che notifica che un nuovo target è stato collegato a questo blocco di messaggistica overwrite_buffer.

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();

sovrascrivi_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 utilizzato è implicito nel 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.

propaga_messaggio

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 sorgente che offre il messaggio.

Valore restituito

Un'indicazione dello stato del messaggio su ciò che il destinatario ha deciso di fare con il messaggio.

propagate_to_any_targets

Posiziona message _PMessage in questo overwrite_buffer blocco di messaggi e lo offre a tutte le destinazioni collegate.

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

Parametri

_PMessage
Un puntatore a un message oggetto di cui questo overwrite_buffer ha preso proprietà.

Osservazioni:

Questo metodo sovrascrive il messaggio corrente in overwrite_buffer con il messaggio _PMessageappena accettato.

invio_messaggio

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 sorgente che offre il messaggio.

Valore restituito

Un'indicazione dello stato del messaggio su ciò che il destinatario ha deciso di fare con il messaggio.

supporta_sorgente_anonima

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.

messaggio_di_rilascio

Rilascia una precedente prenotazione di messaggi.

virtual void release_message(runtime_object_identity _MsgId);

Parametri

_MsgId
runtime_object_identity dell'oggetto message che viene rilasciato.

messaggio_di_riserva

Riserva un messaggio offerto in precedenza da questo overwrite_buffer blocco di messaggistica.

virtual bool reserve_message(runtime_object_identity _MsgId);

Parametri

_MsgId
Elemento runtime_object_identity dell'oggetto message riservato.

Valore restituito

true se il messaggio è stato riservato correttamente, false in caso contrario.

Osservazioni:

Dopo che reserve è stato chiamato, se restituisce true, devono essere chiamati consume o release per prendere o rilasciare la proprietà del messaggio.

resume_propagation

Riprende la propagazione dopo il rilascio di una prenotazione.

virtual void resume_propagation();

valore

Ottiene un riferimento al payload corrente del messaggio archiviato nel overwrite_buffer blocco di messaggistica.

T value();

Valore restituito

Il 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 concorrenza
classe unbounded_buffer
Classe single_assignment