Classe join

Un blocco della messaggistica join è un propagator_block multi-origine, a destinazione singola, che combina insieme messaggi di tipo T da ognuna delle origini.

Sintassi

template<class T,
    join_type _Jtype = non_greedy>
class join : public propagator_block<single_link_registry<ITarget<std::vector<T>>>,
    multi_link_registry<ISource<T>>>;

Parametri

T
Tipo di payload dei messaggi aggiunti e propagati dal blocco.

_Jtype
Il tipo di join blocco è, greedy o non_greedy

Membri

Costruttori pubblici

Metodi protetti

Osservazioni:

Per altre informazioni, vedere Blocchi di messaggi asincroni.

Gerarchia di ereditarietà

ISource

ITarget

source_block

propagator_block

join

Requisiti

Intestazione: agents.h

Spazio dei nomi: Concurrency

accept_message

Accetta un messaggio offerto da questo join blocco di messaggistica, trasferendo la proprietà al chiamante.

virtual message<_OutputType>* 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à.

consume_message

Utilizza un messaggio offerto in precedenza dal join blocco di messaggistica e riservato dalla destinazione, trasferendo la proprietà al chiamante.

virtual message<_OutputType>* 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.

join

Costruisce un blocco della messaggistica join .

join(
    size_t _NumInputs);

join(
    size_t _NumInputs,
    filter_method const& _Filter);

join(
    Scheduler& _PScheduler,
    size_t _NumInputs);

join(
    Scheduler& _PScheduler,
    size_t _NumInputs,
    filter_method const& _Filter);

join(
    ScheduleGroup& _PScheduleGroup,
    size_t _NumInputs);

join(
    ScheduleGroup& _PScheduleGroup,
    size_t _NumInputs,
    filter_method const& _Filter);

Parametri

_NumInputs
Numero di input consentiti da questo join blocco.

_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 join .

_PScheduleGroup
Oggetto ScheduleGroup all'interno del quale è pianificata l'attività di propagazione per il blocco della messaggistica join . 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 join blocco di messaggistica per determinare se deve accettare o meno un messaggio offerto.

~unire

Distrugge il join blocco.

~join();

link_target_notification

Callback che notifica che una nuova destinazione è stata collegata a questo join blocco di messaggistica.

virtual void link_target_notification(_Inout_ ITarget<std::vector<T>> *);

propagate_message

Passa in modo asincrono un messaggio da un ISource blocco a questo join blocco di messaggistica. Viene richiamato dal propagate metodo , quando viene chiamato da un blocco di origine.

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

Costruisce un messaggio di output contenente un messaggio di input da ogni origine quando tutti hanno propagato un messaggio. Invia questo messaggio di output a ognuna delle destinazioni.

void propagate_to_any_targets(_Inout_opt_ message<_OutputType> *);

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 join blocco di messaggistica.

virtual bool reserve_message(runtime_object_identity _MsgId);

Parametri

_MsgId
Oggetto runtime_object_identity dell'oggetto offerto message .

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

Vedi anche

Spazio dei nomi concurrency
Classe choice
Classe multitype_join