BatchBlock<T> Clase

Definición

Espacio de nombres:

System.Threading.Tasks.Dataflow

Ensamblado:

System.Threading.Tasks.Dataflow.dll

Proporciona un bloque de flujo de datos que procesa por lotes las entradas en las matrices.

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)

Parámetros de tipo

T

Especifica el tipo de datos guardados en lotes.

Herencia

Object

BatchBlock<T>

Implementaciones

IDataflowBlock IPropagatorBlock<T,T[]> IReceivableSourceBlock<T[]> ISourceBlock<T[]> ISourceBlock<TOutput> ITargetBlock<T> ITargetBlock<TInput>

Comentarios

Nota

La biblioteca de flujos de datos TPL (el espacio de nombres System.Threading.Tasks.Dataflow) no se distribuye con .NET. Para instalar el espacio de nombres System.Threading.Tasks.Dataflow en Visual Studio, abra el proyecto, seleccione Administrar paquetes NuGet en el menú Proyecto y busque en línea el paquete System.Threading.Tasks.Dataflow. Como alternativa, para realizar la instalación con la CLI de .Net Core, ejecute dotnet add package System.Threading.Tasks.Dataflow.

Constructores

BatchBlock<T>(Int32)	Inicializa una nueva instancia de BatchBlock<T> con el tamaño de lote especificado.
BatchBlock<T>(Int32, GroupingDataflowBlockOptions)	Inicializa una nueva BatchBlock<T> con el tamaño de lote especificado, la opción de rechazo y las opciones de bloque.

Propiedades

BatchSize	Obtiene el tamaño de los lotes generados por BatchBlock<T>.
Completion	Obtiene un objeto Task que representa la operación asincrónica y la finalización del bloque de flujo de datos.
OutputCount	Obtiene el número de elementos de salida disponibles que se pueden recibir de este bloque.

Métodos

Complete()	Señala a IDataflowBlock que no debe aceptar ni mostrar más mensajes ni usar más mensajes pospuestos.
Equals(Object)	Determina si el objeto especificado es igual que el objeto actual. (Heredado de Object)
GetHashCode()	Sirve como la función hash predeterminada. (Heredado de Object)
GetType()	Obtiene el Type de la instancia actual. (Heredado de Object)
LinkTo(ITargetBlock<T[]>, DataflowLinkOptions)	Vincula el ISourceBlock<TOutput> al ITargetBlock<TInput> especificado.
MemberwiseClone()	Crea una copia superficial del Object actual. (Heredado de Object)
ToString()	Devuelve una cadena que representa el nombre con formato de esta instancia de IDataflowBlock.
TriggerBatch()	Desencadena BatchBlock<T> para iniciar una operación de procesamiento por lotes incluso si el número de elementos actualmente en cola o pospuestos es menor que BatchSize.
TryReceive(Predicate<T[]>, T[])	Intentos de recibir sincrónicamente un elemento de salida disponible de IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<T[]>)	Intentos de recibir sincrónicamente todos los elementos disponibles de IReceivableSourceBlock<TOutput>.

Implementaciones de interfaz explícitas

IDataflowBlock.Fault(Exception)	Hace que IDataflowBlock se complete en un estado Faulted.
ISourceBlock<T[]>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T[]>, Boolean)	Lo llama una ITargetBlock<TInput> vinculada para aceptar y consumir una DataflowMessageHeader ofrecida previamente por esta ISourceBlock<TOutput>.
ISourceBlock<T[]>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T[]>)	Lo llama una interfaz ITargetBlock<TInput> vinculada para liberar una estructura DataflowMessageHeader reservada previamente por esta interfaz ISourceBlock<TOutput>.
ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T[]>)	Lo llama una interfaz ITargetBlock<TInput> vinculada para reservar una estructura DataflowMessageHeader ofrecida previamente por esta interfaz ISourceBlock<TOutput>.
ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean)	Ofrece un mensaje a ITargetBlock<TInput>, dando al destino la oportunidad de usar o de posponer el mensaje.

Métodos de extensión

AsObservable<TOutput>(ISourceBlock<TOutput>)	Crea una nueva abstracción de la interfaz IObservable<T> sobre la interfaz ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)	Crea una abstracción de IObserver<T> sobre ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Vincula el ISourceBlock<TOutput> al ITargetBlock<TInput> especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Vincula el ISourceBlock<TOutput> al ITargetBlock<TInput> especificado con el filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Vincula el ISourceBlock<TOutput> al ITargetBlock<TInput> especificado con el filtro especificado.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de salida disponible.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Proporciona una Task<TResult> que supervisa de manera asincrónica la salida disponible en el origen.
Post<TInput>(ITargetBlock<TInput>, TInput)	Publica un elemento a ITargetBlock<TInput>.
Receive<TOutput>(ISourceBlock<TOutput>)	Recibe de forma sincrónica un valor de un origen especificado.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	De forma sincrónica recibe un valor de un origen especificado y proporciona un token para cancelar la operación.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	De forma sincrónica recibe un valor de un origen especificado, observando un tiempo de espera opcional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	De forma sincrónica recibe un valor de un origen especificado, proporcionando un token para cancelar la operación y observando un intervalo de tiempo de espera opcional.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Crea un objeto IAsyncEnumerable<T> que permite recibir todos los datos del origen.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Recibe de forma asincrónica un valor de un origen especificado.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	De forma asincrónica recibe un valor de un origen especificado y proporciona un token para cancelar la operación.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	De forma asincrónica recibe un valor de un origen especificado, observando un tiempo de espera opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	De forma asincrónica recibe un valor de un origen especificado, proporcionando un símbolo para anular la operación y observando un intervalo de tiempo de espera opcional.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	De forma asincrónica proporciona un mensaje al bloque de mensajes de destino, teniendo en cuenta el aplazamiento.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	De forma asincrónica proporciona un mensaje al bloque de mensajes de destino, teniendo en cuenta el aplazamiento.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Se intenta recibir sincrónicamente un elemento de ISourceBlock<TOutput>.