BatchBlock<T> 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 del flusso di dati che raggruppa in matrici gli input.
generic <typename T>
public ref class BatchBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, cli::array <T> ^>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ITargetBlock<T>public sealed class BatchBlock<T> : System.Threading.Tasks.Dataflow.IPropagatorBlock<T,T[]>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<T[]>, System.Threading.Tasks.Dataflow.ISourceBlock<T[]>, System.Threading.Tasks.Dataflow.ITargetBlock<T>type BatchBlock<'T> = class
interface IPropagatorBlock<'T, 'T[]>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T[]>
interface IReceivableSourceBlock<'T[]>type BatchBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T[]>
interface ISourceBlock<'T[]>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T[]>Public NotInheritable Class BatchBlock(Of T)
Implements IPropagatorBlock(Of T, T()), IReceivableSourceBlock(Of T()), ISourceBlock(Of T()), ITargetBlock(Of T)Parametri di tipo
- T
Specifica il tipo di dati inseriti in batch.
- Ereditarietà
-
BatchBlock<T>
- Implementazioni
Commenti
Nota
La libreria del flusso di dati TPL (spazio dei nomi System.Threading.Tasks.Dataflow) non viene distribuita con .NET. Per installare lo spazio dei nomi System.Threading.Tasks.Dataflow in Visual Studio, aprire il progetto in Visual Studio, scegliere Gestisci pacchetti NuGet dal menu Progetto ed eseguire una ricerca online del pacchetto System.Threading.Tasks.Dataflow. In alternativa, per installarlo usando l'interfaccia della riga di comando di .NET Core, eseguire dotnet add package System.Threading.Tasks.Dataflow.
Costruttori
| BatchBlock<T>(Int32) |
Inizializza una nuova istanza di BatchBlock<T> con le dimensione del batch specificate. |
| BatchBlock<T>(Int32, GroupingDataflowBlockOptions) |
Inizializza una nuova classe BatchBlock<T> con le dimensioni del batch, l'opzione di rifiuto e le opzioni di blocco specificate. |
Proprietà
| BatchSize |
Ottiene la dimensione dei batch generati da questo BatchBlock<T>. |
| Completion |
Ottiene un Task che rappresenta l'operazione asincrona e il completamento del blocco di flussi di dati. |
| OutputCount |
Ottiene il numero di elemento di output disponibili alla ricezione da questo blocco. |
Metodi
| Complete() |
Segnala al IDataflowBlock che non deve accettare o produrre altri messaggi e non deve 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 l'oggetto Type dell'istanza corrente. (Ereditato da Object) |
| LinkTo(ITargetBlock<T[]>, DataflowLinkOptions) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> . |
| MemberwiseClone() |
Crea una copia superficiale dell'oggetto Object corrente. (Ereditato da Object) |
| ToString() |
Restituisce una stringa che rappresenta il nome formattato di questa istanza IDataflowBlock. |
| TriggerBatch() |
Attiva BatchBlock<T> per avviare un'operazione di suddivisione in batch anche se il numero di elementi attualmente in coda o posticipati è minore di BatchSize. |
| TryReceive(Predicate<T[]>, T[]) |
Tenta di ricevere in modo sincrono un elemento di output disponibile da IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<T[]>) |
Tenta di ricevere in modo sincrono tutti gli elementi disponibili dal IReceivableSourceBlock<TOutput>. |
Implementazioni dell'interfaccia esplicita
Metodi di estensione
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crea una nuova astrazione IObservable<T> rispetto a ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Crea una nuova astrazione IObserver<T> rispetto a ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput>. |
| 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>, DataflowLinkOptions, Predicate<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Inserisce un elemento nell'oggetto ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Riceve un valore in modo sincrono da un'origine specificata. |
| 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) |
Riceve in modo sincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo. |
| 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. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Crea un oggetto IAsyncEnumerable<T> che consente la ricezione di tutti i dati dall'origine. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Riceve un valore in modo asincrono da un'origine specificata. |
| 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) |
Riceve in modo asincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo. |
| 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. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
In modo asincrono offre un messaggio al blocco di messaggi di destinazione, consentendo il rinvio. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
In modo asincrono offre un messaggio al blocco di messaggi di destinazione, consentendo il rinvio. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tenta di ricevere in modo sincrono un elemento da ISourceBlock<TOutput>. |
