System.Threading.Tasks.Dataflow Espace de noms

Fournit un modèle de programmation basé sur acteur qui prend en charge le passage des messages in-process pour les tâches de flux de données à granularité grossière et de traitement pipeline.

Classes

ActionBlock<TInput>

Fournit un bloc de flux de données qui appelle un délégué Action<T> fourni pour chaque élément de données reçu.

BatchBlock<T>

Fournit un bloc de flux de données qui traite par lot les entrées dans les tableaux.

BatchedJoinBlock<T1,T2>

Fournit un bloc de flux de données qui traite par lot un nombre spécifié d'entrées de types potentiellement différents fournis à une ou plusieurs de ses cibles.

BatchedJoinBlock<T1,T2,T3>

Fournit un bloc de flux de données qui traite par lot un nombre spécifié d'entrées de types potentiellement différents fournis à une ou plusieurs de ses cibles.

BroadcastBlock<T>

Fournit une mémoire tampon pour stocker au plus un élément à la fois, en remplaçant chaque message par le suivant lorsque ce dernier arrive.

BufferBlock<T>

Fournit une mémoire tampon pour stocker des données pour un flux de données.

DataflowBlock

Fournit un ensemble de méthodes statiques (Shared en Visual Basic) pour utiliser des blocs de flux de données.

DataflowBlockOptions

Fournit les options utilisées pour configurer le traitement exécuté par les blocs de flux de données.

DataflowLinkOptions

Fournit les options utilisées pour configurer un lien entre des blocs de flux de données.

ExecutionDataflowBlockOptions

Fournit les options utilisées pour configurer le traitement effectué par les blocs de flux de données qui traitent chaque message via l'appel d'un délégué fourni par l'utilisateur. Il s’agit de blocs de flux de données tels que ActionBlock<TInput> et TransformBlock<TInput,TOutput>.

GroupingDataflowBlockOptions

Fournit les options utilisées pour configurer le traitement effectué par les blocs de flux de données qui regroupent plusieurs messages. Il s’agit de blocs de flux de données tels que JoinBlock<T1,T2> et BatchBlock<T>.

JoinBlock<T1,T2>

Fournit un bloc de flux de données qui se connecte à plusieurs sources de flux de données, pas nécessairement du même type, et attend l’arrivée d’un élément pour chaque type avant qu’ils ne soient libérés tous ensemble sous forme de tuple composé d’un élément par type.

JoinBlock<T1,T2,T3>

Fournit un bloc de flux de données qui se connecte à plusieurs sources de flux de données, qui ne sont pas nécessairement du même type, et attend l’arrivée d’un élément pour chaque type avant qu’ils ne soient libérés tous ensemble sous forme de tuple contenant un élément par type.

TransformBlock<TInput,TOutput>

Fournit un bloc de flux de données qui appelle un délégué Func<T,TResult> fourni pour chaque élément de données reçu.

TransformManyBlock<TInput,TOutput>

Fournit un bloc de flux de données qui appelle un délégué Func<T,TResult> fourni pour chaque élément de données reçu.

WriteOnceBlock<T>

Fournit une mémoire tampon pour recevoir et stocker au plus un élément dans un réseau de blocs de flux de données.

Structures

DataflowMessageHeader

Fournit un conteneur d'attributs de données pour passer ces attributs de données entre les blocs de flux de données.

Interfaces

IDataflowBlock

Représente un bloc de flux de données.

IPropagatorBlock<TInput,TOutput>

Représente un bloc de flux de données qui est une cible pour les données et une source de données.

IReceivableSourceBlock<TOutput>

Représente un bloc de flux de données qui prend en charge la réception des messages sans liaison.

ISourceBlock<TOutput>

Représente un bloc de flux de données qui est une source de données.

ITargetBlock<TInput>

Représente un bloc de flux de données qui est une cible pour les données.

Énumérations

DataflowMessageStatus

Représente l'état d'un DataflowMessageHeader lorsqu'il est passé entre les blocs de flux de données.

Remarques

Notes

La bibliothèque de flux de données TPL (espace de noms System.Threading.Tasks.Dataflow) n'est pas distribuée avec .NET. Pour installer l’espace de noms System.Threading.Tasks.Dataflow dans Visual Studio, ouvrez votre projet, choisissez Gérer les packages NuGet dans le menu Projet, puis recherchez en ligne le package System.Threading.Tasks.Dataflow. Vous pouvez également l’installer à l’aide de l’interface CLI .NET Core en exécutant dotnet add package System.Threading.Tasks.Dataflow.

Pour plus d’informations, consultez Flux de données.