BatchBlock<T> Classe

Definizione

Spazio dei nomi:
System.Threading.Tasks.Dataflow
Assembly:
System.Threading.Tasks.Dataflow.dll

Fornisce un blocco di flussi di dati che inserisce gli input in matrici.

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[]>
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à
Object
BatchBlock<T>
Implementazioni
IDataflowBlock IPropagatorBlock<T,T[]> IReceivableSourceBlock<T[]> ISourceBlock<T[]> ISourceBlock<TOutput> ITargetBlock<T> ITargetBlock<TInput>

Commenti

Note

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, scegliere Gestisci pacchetti NuGet dal menu Project e cercare online il 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

Nome Descrizione
BatchBlock<T>(Int32, GroupingDataflowBlockOptions)

Inizializza un nuovo BatchBlock<T> oggetto con le dimensioni del batch, l'opzione di rifiuto e le opzioni di blocco specificate.
BatchBlock<T>(Int32)

Inizializza un nuovo BatchBlock<T> oggetto con le dimensioni del batch specificate.

Proprietà

Nome Descrizione
BatchSize

Ottiene le dimensioni dei batch generati da questo BatchBlock<T>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.

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<T[]>, 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.
TriggerBatch()

Attiva l'oggetto BatchBlock<T> per avviare un'operazione di invio 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 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<T[]>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T[]>, Boolean)

Chiamato da un oggetto collegato ITargetBlock<TInput> per accettare e utilizzare un DataflowMessageHeader oggetto offerto in precedenza da questo ISourceBlock<TOutput> oggetto .
ISourceBlock<T[]>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T[]>)

Chiamato da un oggetto collegato ITargetBlock<TInput> per rilasciare un oggetto precedentemente riservato DataflowMessageHeader da questo ISourceBlock<TOutput>oggetto .
ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T[]>)

Chiamato da un oggetto collegato ITargetBlock<TInput> per riservare un oggetto offerto DataflowMessageHeader in precedenza da questo ISourceBlock<TOutput>oggetto .
ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean)

Offre un messaggio all'oggetto ITargetBlock<TInput>, offrendo alla destinazione la possibilità di utilizzare o posticipare il messaggio.

Metodi di estensione

Nome Descrizione
AsObservable<TOutput>(ISourceBlock<TOutput>)

Crea una nuova IObservable<T> astrazione su ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)

Crea una nuova IObserver<T> astrazione su ITargetBlock<TInput>.
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.
Post<TInput>(ITargetBlock<TInput>, TInput)

Inserisce un elemento nell'oggetto ITargetBlock<TInput>.
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.
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.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)

Offre in modo asincrono un messaggio al blocco di messaggi di destinazione, consentendo il posticipo.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)

Offre in modo asincrono un messaggio al blocco di messaggi di destinazione, consentendo il posticipo.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Tenta di ricevere in modo sincrono un elemento da ISourceBlock<TOutput>.

Si applica a