BatchedJoinBlock<T1,T2> 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>
public ref class BatchedJoinBlock sealed : System::Threading::Tasks::Dataflow::IReceivableSourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^>public sealed class BatchedJoinBlock<T1,T2> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>type BatchedJoinBlock<'T1, 'T2> = class
interface IReceivableSourceBlock<IList<'T1> * IList<'T2>>
interface ISourceBlock<IList<'T1> * IList<'T2>>
interface IDataflowBlocktype BatchedJoinBlock<'T1, 'T2> = class
interface IDataflowBlock
interface IReceivableSourceBlock<IList<'T1> * IList<'T2>>
interface ISourceBlock<IList<'T1> * IList<'T2>>Public NotInheritable Class BatchedJoinBlock(Of T1, T2)
Implements IReceivableSourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2))), ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2)))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.
- Ereditarietà
-
BatchedJoinBlock<T1,T2>
- Implementazioni
-
IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>>> ISourceBlock<Tuple<IList<T1>,IList<T2>>> ISourceBlock<TOutput>
Costruttori
| Nome | Descrizione |
|---|---|
| BatchedJoinBlock<T1,T2>(Int32, GroupingDataflowBlockOptions) |
Inizializza un nuovo BatchedJoinBlock<T1,T2> oggetto con la configurazione specificata. |
| BatchedJoinBlock<T1,T2>(Int32) |
Inizializza un nuovo BatchedJoinBlock<T1,T2> oggetto con la configurazione specificata. |
Proprietà
| Nome | Descrizione |
|---|---|
| BatchSize |
Ottiene le dimensioni dei batch generati da questo BatchedJoinBlock<T1,T2>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. |
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>>>, 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>>>, Tuple<IList<T1>,IList<T2>>) |
Tenta di ricevere in modo sincrono un elemento di output disponibile da IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>>>) |
Tenta di ricevere in modo sincrono tutti gli elementi disponibili da IReceivableSourceBlock<TOutput>. |
Implementazioni dell'interfaccia esplicita
| Nome | Descrizione |
|---|---|
| IDataflowBlock.Fault(Exception) |
Fa sì che l'oggetto IDataflowBlock venga completato in uno Faulted stato. |
| ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>, Boolean) |
Passa la proprietà del messaggio identificato da da DataflowMessageHeader questa ISourceBlock<TOutput> istanza a ITargetBlock<TInput>. |
| ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>) |
Rilascia il diritto di passare la proprietà del messaggio identificato da DataflowMessageHeader da questo ISourceBlock<TOutput> all'oggetto ITargetBlock<TInput>. |
| ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>) |
Si riserva il diritto di passare la proprietà del messaggio identificato da DataflowMessageHeader da questo ISourceBlock<TOutput> all'oggetto ITargetBlock<TInput>. |
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>. |
