System.Threading.Tasks.Dataflow Namespace

Fornece um modelo de programação baseado em ator que dá suporte à passagem de mensagens em processo para tarefas de fluxo de dados e pipelining grosseiras.

Classes

Nome Description
ActionBlock<TInput>

Fornece um bloco de fluxo de dados que invoca um delegado fornecido Action<T> para cada elemento de dados recebido.

BatchBlock<T>

Fornece um bloco de fluxo de dados que agrupa em lotes entradas em matrizes.

BatchedJoinBlock<T1,T2>

Fornece um bloco de fluxo de dados que agrupa um número especificado de entradas de tipos potencialmente diferentes fornecidos para um ou mais de seus destinos.

BatchedJoinBlock<T1,T2,T3>

Fornece um bloco de fluxo de dados que agrupa um número especificado de entradas de tipos potencialmente diferentes fornecidos para um ou mais de seus destinos.

BroadcastBlock<T>

Fornece um buffer para armazenar no máximo um elemento no momento, substituindo cada mensagem com o próximo conforme ele chega.

BufferBlock<T>

Fornece um buffer para armazenar dados para um fluxo de dados.

DataflowBlock

Fornece um conjunto de métodos estáticos (compartilhados em Visual Basic) para trabalhar com blocos de fluxo de dados.

DataflowBlockOptions

Fornece opções usadas para configurar o processamento executado por blocos de fluxo de dados.

DataflowLinkOptions

Fornece opções usadas para configurar um link entre blocos de fluxo de dados.

ExecutionDataflowBlockOptions

Fornece opções usadas para configurar o processamento executado por blocos de fluxo de dados que processam cada mensagem por meio da invocação de um delegado fornecido pelo usuário. Estes são blocos de fluxo de dados, como ActionBlock<TInput> e TransformBlock<TInput,TOutput>.

GroupingDataflowBlockOptions

Fornece opções usadas para configurar o processamento executado por blocos de fluxo de dados que agrupam várias mensagens. Estes são blocos de fluxo de dados, como JoinBlock<T1,T2> e BatchBlock<T>.

JoinBlock<T1,T2>

Fornece um bloco de fluxo de dados que se une a várias fontes de fluxo de dados, não necessariamente do mesmo tipo, aguardando que um item chegue para cada tipo antes que todos sejam lançados juntos como uma tupla que consiste em um item por tipo.

JoinBlock<T1,T2,T3>

Fornece um bloco de fluxo de dados que se une a várias fontes de fluxo de dados, que não são necessariamente do mesmo tipo, aguardando que um item chegue para cada tipo antes que todos sejam liberados juntos como uma tupla que contém um item por tipo.

TransformBlock<TInput,TOutput>

Fornece um bloco de fluxo de dados que invoca um delegado fornecido Func<T,TResult> para cada elemento de dados recebido.

TransformManyBlock<TInput,TOutput>

Fornece um bloco de fluxo de dados que invoca um delegado fornecido Func<T,TResult> para cada elemento de dados recebido.

WriteOnceBlock<T>

Fornece um buffer para receber e armazenar no máximo um elemento em uma rede de blocos de fluxo de dados.

Estruturas

Nome Description
DataflowMessageHeader

Fornece um contêiner de atributos de dados para passar entre blocos de fluxo de dados.

Interfaces

Nome Description
IDataflowBlock

Representa um bloco de fluxo de dados.

IPropagatorBlock<TInput,TOutput>

Representa um bloco de fluxo de dados que é um destino para dados e uma fonte de dados.

IReceivableSourceBlock<TOutput>

Representa um bloco de fluxo de dados que dá suporte ao recebimento de mensagens sem vinculação.

ISourceBlock<TOutput>

Representa um bloco de fluxo de dados que é uma fonte de dados.

ITargetBlock<TInput>

Representa um bloco de fluxo de dados que é um destino para dados.

Enumerações

Nome Description
DataflowMessageStatus

Representa o status de um DataflowMessageHeader quando passado entre blocos de fluxo de dados.

Comentários

Note

A Biblioteca de Fluxo de Dados TPL (o namespace System.Threading.Tasks.Dataflow) não é distribuída com .NET. Para instalar o namespace System.Threading.Tasks.Dataflow no Visual Studio, abra seu projeto, escolha Gerenciar Pacotes NuGet no menu do Projeto e pesquise online o pacote System.Threading.Tasks.Dataflow. Como alternativa, instale-o usando a CLI do .NET Core e execute dotnet add package System.Threading.Tasks.Dataflow.

Para obter mais informações, consulte Fluxo de dados.