BatchedJoinBlock<T1,T2,T3> Clase

Definición

Espacio de nombres:

System.Threading.Tasks.Dataflow

Ensamblado:

System.Threading.Tasks.Dataflow.dll

Paquete:

System.Threading.Tasks.Dataflow v11.0.0-rc.1.26425.128

Source:

BatchedJoinBlock.cs

Proporciona un bloque de flujo de datos que agrupa por lotes un número especificado de entradas de tipos potencialmente diferentes proporcionados a uno o varios de sus destinos.

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

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)))

Parámetros de tipo

T1

Especifica el tipo de datos aceptados por el primer destino del bloque.

T2

Especifica el tipo de datos aceptados por el segundo destino del bloque.

T3

Especifica el tipo de datos aceptados por el tercer destino del bloque.

Herencia

Object

BatchedJoinBlock<T1,T2,T3>

Implementaciones

IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<TOutput>

Constructores

Nombre	Description
BatchedJoinBlock<T1,T2,T3>(Int32, GroupingDataflowBlockOptions)	Inicializa un nuevo BatchedJoinBlock<T1,T2,T3> con la configuración especificada.
BatchedJoinBlock<T1,T2,T3>(Int32)	Inicializa un nuevo BatchedJoinBlock<T1,T2,T3> con la configuración especificada.

Propiedades

Nombre	Description
BatchSize	Obtiene el tamaño de los lotes generados por este BatchedJoinBlock<T1,T2,T3>.
Completion	Obtiene un Task objeto 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 para recibirse de este bloque.
Target1	Obtiene un destino que se puede usar para ofrecer mensajes del primer tipo.
Target2	Obtiene un destino que se puede usar para ofrecer mensajes del segundo tipo.
Target3	Obtiene un destino que se puede usar para ofrecer mensajes del tercer tipo.

Métodos

Nombre	Description
Complete()	Señala a que IDataflowBlock no debe aceptar ni producir más mensajes ni consumir más mensajes pospuestos.
LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, DataflowLinkOptions)	Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput> .
ToString()	Devuelve una cadena que representa el nombre con formato de esta IDataflowBlock instancia.
TryReceive(Predicate<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Tuple<IList<T1>,IList<T2>,IList<T3>>)	Intenta recibir de forma sincrónica un elemento de salida disponible de .IReceivableSourceBlock<TOutput>
TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Intenta recibir de forma sincrónica todos los elementos disponibles de IReceivableSourceBlock<TOutput>.

Implementaciones de interfaz explícitas

Nombre	Description
IDataflowBlock.Fault(Exception)	Hace que se IDataflowBlock complete en un Faulted estado .
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Boolean)	Pasa la propiedad del mensaje identificado por de DataflowMessageHeader esta ISourceBlock<TOutput> instancia a .ITargetBlock<TInput>
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Libera el derecho para pasar la propiedad del mensaje identificado por de DataflowMessageHeader este ISourceBlock<TOutput> a .ITargetBlock<TInput>
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Se reserva el derecho de pasar la propiedad del mensaje identificado por de DataflowMessageHeader este ISourceBlock<TOutput> a .ITargetBlock<TInput>

Métodos de extensión

Nombre	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	Crea una nueva IObservable<T> abstracción sobre .ISourceBlock<TOutput>
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Recibe sincrónicamente un valor de un origen especificado y proporciona un token para cancelar la operación.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Recibe sincrónicamente un valor de un origen especificado, proporcionando un token para cancelar la operación y observar un intervalo de tiempo de espera opcional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Recibe sincrónicamente un valor de un origen especificado, observando un período de tiempo de espera opcional.
Receive<TOutput>(ISourceBlock<TOutput>)	Recibe sincrónicamente un valor de un origen especificado.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Crea un objeto IAsyncEnumerable<T> que permite recibir todos los datos del origen.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Recibe de forma asincrónica un valor de un origen especificado y proporciona un token para cancelar la operación.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Recibe de forma asincrónica un valor de un origen especificado, lo que proporciona un token para cancelar la operación y observar un intervalo de tiempo de espera opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Recibe de forma asincrónica un valor de un origen especificado, observando un período de tiempo de espera opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Recibe de forma asincrónica un valor de un origen especificado.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Intenta recibir de forma sincrónica un elemento de .ISourceBlock<TOutput>