BatchedJoinBlock<T1,T2,T3> Classe
Definizione
Importante
Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.
Fornisce un blocco di flussi di dati che esegue il batch di un numero specificato di input di tipi potenzialmente diversi forniti a una o più destinazioni.
generic <typename T1, typename T2, typename T3>
public ref class BatchedJoinBlock sealed : System::Threading::Tasks::Dataflow::IReceivableSourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^, System::Collections::Generic::IList<T3> ^> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^, System::Collections::Generic::IList<T3> ^> ^>
public sealed class BatchedJoinBlock<T1,T2,T3> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>
type BatchedJoinBlock<'T1, 'T2, 'T3> = class
interface IReceivableSourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
interface ISourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
interface IDataflowBlock
type BatchedJoinBlock<'T1, 'T2, 'T3> = class
interface IDataflowBlock
interface IReceivableSourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
interface ISourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
Public NotInheritable Class BatchedJoinBlock(Of T1, T2, T3)
Implements IReceivableSourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2), IList(Of T3))), ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2), IList(Of T3)))
Parametri di tipo
- T1
Specifica il tipo di dati accettati dalla prima destinazione del blocco.
- T2
Specifica il tipo di dati accettati dalla seconda destinazione del blocco.
- T3
Specifica il tipo di dati accettati dalla terza destinazione del blocco.
- Ereditarietà
-
BatchedJoinBlock<T1,T2,T3>
- Implementazioni
-
IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<TOutput>
Costruttori
| Nome | Descrizione |
|---|---|
| BatchedJoinBlock<T1,T2,T3>(Int32, GroupingDataflowBlockOptions) |
Inizializza un nuovo BatchedJoinBlock<T1,T2,T3> oggetto con la configurazione specificata. |
| BatchedJoinBlock<T1,T2,T3>(Int32) |
Inizializza un nuovo BatchedJoinBlock<T1,T2,T3> oggetto con la configurazione specificata. |
Proprietà
| Nome | Descrizione |
|---|---|
| BatchSize |
Ottiene le dimensioni dei batch generati da questo BatchedJoinBlock<T1,T2,T3>oggetto . |
| Completion |
Ottiene un oggetto Task che rappresenta l'operazione asincrona e il completamento del blocco del flusso di dati. |
| OutputCount |
Ottiene il numero di elementi di output disponibili da ricevere da questo blocco. |
| Target1 |
Ottiene una destinazione che può essere utilizzata per offrire messaggi del primo tipo. |
| Target2 |
Ottiene una destinazione che può essere utilizzata per offrire messaggi del secondo tipo. |
| Target3 |
Ottiene una destinazione che può essere utilizzata per offrire messaggi del terzo tipo. |
Metodi
| Nome | Descrizione |
|---|---|
| Complete() |
Segnala all'oggetto IDataflowBlock che non deve accettare né produrre altri messaggi né utilizzare altri messaggi posticipati. |
| Equals(Object) |
Determina se l'oggetto specificato è uguale all'oggetto corrente. (Ereditato da Object) |
| GetHashCode() |
Funge da funzione hash predefinita. (Ereditato da Object) |
| GetType() |
Ottiene il Type dell'istanza corrente. (Ereditato da Object) |
| LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, DataflowLinkOptions) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> . |
| MemberwiseClone() |
Crea una copia superficiale del Objectcorrente. (Ereditato da Object) |
| ToString() |
Restituisce una stringa che rappresenta il nome formattato di questa IDataflowBlock istanza. |
| TryReceive(Predicate<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Tuple<IList<T1>,IList<T2>,IList<T3>>) |
Tenta di ricevere in modo sincrono un elemento di output disponibile da IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>,IList<T3>>>) |
Tenta di ricevere in modo sincrono tutti gli elementi disponibili da IReceivableSourceBlock<TOutput>. |
Implementazioni dell'interfaccia esplicita
Metodi di estensione
| Nome | Descrizione |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crea una nuova IObservable<T> astrazione su ISourceBlock<TOutput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput>. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Riceve in modo sincrono un valore da un'origine specificata e fornisce un token per annullare l'operazione. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Riceve in modo sincrono un valore da un'origine specificata, fornendo un token per annullare l'operazione e osservando un intervallo di timeout facoltativo. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Riceve in modo sincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Riceve in modo sincrono un valore da un'origine specificata. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Crea un oggetto IAsyncEnumerable<T> che consente di ricevere tutti i dati dall'origine. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Riceve in modo asincrono un valore da un'origine specificata e fornisce un token per annullare l'operazione. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Riceve in modo asincrono un valore da un'origine specificata, fornendo un token per annullare l'operazione e osservando un intervallo di timeout facoltativo. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Riceve in modo asincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Riceve in modo asincrono un valore da un'origine specificata. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tenta di ricevere in modo sincrono un elemento da ISourceBlock<TOutput>. |