Compartir vía


System.Threading.Tasks.Dataflow Espacio de nombres

Proporciona un modelo de programación basado en actores que admite el paso de mensajes en proceso para el flujo de datos general y las tareas de canalización.

Clases

ActionBlock<TInput>

Proporciona un bloque de flujo de datos que invoca un delegado proporcionado de Action<T> para cada elemento de datos recibido.

BatchBlock<T>

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

BatchedJoinBlock<T1,T2>

Proporciona un bloque de flujo de datos que procesa por lotes un número especificado de entradas de tipos potencialmente distintos proporcionados a uno o más de sus destinos.

BatchedJoinBlock<T1,T2,T3>

Proporciona un bloque de flujo de datos que procesa por lotes un número especificado de entradas de tipos potencialmente distintos proporcionados a uno o más de sus destinos.

BroadcastBlock<T>

Proporciona un búfer para almacenar a lo sumo un elemento cada vez, sobrescribiendo cada mensaje con el siguiente a medida que llegan.

BufferBlock<T>

Proporciona un búfer para almacenar datos de un Dataflow.

DataflowBlock

Proporciona un conjunto de métodos estáticos (Shared en Visual Basic) para que funcionen con bloques de flujo de datos.

DataflowBlockOptions

Proporciona las opciones usadas para configurar el procesamiento que realizan los bloques de flujo de datos.

DataflowLinkOptions

Proporciona las opciones usadas para configurar un vínculo entre bloques de flujo de datos.

ExecutionDataflowBlockOptions

Proporciona las opciones usadas para configurar el procesamiento realizado por los bloques de flujo de datos que procesan cada mensaje mediante la invocación de un delegado proporcionado por el usuario. Se trata de bloques de flujo de datos como ActionBlock<TInput> y TransformBlock<TInput,TOutput>.

GroupingDataflowBlockOptions

Proporciona las opciones usadas para configurar el procesamiento que realizan los bloques de flujo de datos que agrupan varios mensajes. Se trata de bloques de flujo de datos como JoinBlock<T1,T2> y BatchBlock<T>.

JoinBlock<T1,T2>

Proporciona un bloque de flujo de datos que combina varios orígenes de flujo de datos, no necesariamente del mismo tipo, donde se espera a que llegue un elemento de cada tipo antes de que todos se liberen de forma conjunta como una tupla que consta de un elemento por tipo.

JoinBlock<T1,T2,T3>

Proporciona un bloque de flujo de datos que combina varios orígenes de flujo de datos, que no son necesariamente del mismo tipo, donde se espera a que llegue un elemento de cada tipo antes de que todos queden libres de forma conjunta como una tupla que contiene un elemento por tipo.

TransformBlock<TInput,TOutput>

Proporciona un bloque de flujo de datos que invoca un delegado proporcionado de Func<T,TResult> para cada elemento de datos recibido.

TransformManyBlock<TInput,TOutput>

Proporciona un bloque de flujo de datos que invoca un delegado proporcionado de Func<T,TResult> para cada elemento de datos recibido.

WriteOnceBlock<T>

Proporciona un búfer para recibir y almacenar a lo sumo un elemento en una red de bloques de flujo de datos.

Estructuras

DataflowMessageHeader

Proporciona un contenedor de atributos de datos para pasarlo entre los bloques de flujo de datos.

Interfaces

IDataflowBlock

Representa un bloque de flujo de datos.

IPropagatorBlock<TInput,TOutput>

Representa un bloque de flujo de datos que es tanto un destino como un origen de datos.

IReceivableSourceBlock<TOutput>

Representa un bloque de flujo de datos que admite la recepción de mensajes sin vincular.

ISourceBlock<TOutput>

Representa un bloque de flujo de datos que es un origen de datos.

ITargetBlock<TInput>

Representa un bloque de flujo de datos que es un destino de datos.

Enumeraciones

DataflowMessageStatus

Representa el estado de un elemento DataflowMessageHeader cuando se pasa entre bloques de flujo de datos.

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.

Para más información, vea Flujo de datos (biblioteca TPL).