System.Threading.Tasks.Dataflow Namespace

Dieser Namespace stellt ein akteurbasiertes Programmiermodell bereit, das die prozessinterne Nachrichtenübergabe für einfache Datenfluss- und Pipelinetasks unterstützt.

Klassen

ActionBlock<TInput>

Stellt einen Datenflussblock bereit, der einen bereitgestellten Action<T>-Delegaten für jede empfangene Datenelement aufruft.

BatchBlock<T>

Stellt einen Datenflussblock bereit, der Eingaben in Arrays stapelt.

BatchedJoinBlock<T1,T2>

Stellt einen Datenflussblock bereit, der stapelweise eine festgelegte Anzahl von Eingaben aus möglicherweise anderen Typen verarbeitet, die einem oder mehreren seiner Ziele bereitgestellt werden.

BatchedJoinBlock<T1,T2,T3>

Stellt einen Datenflussblock bereit, der stapelweise eine festgelegte Anzahl von Eingaben aus möglicherweise anderen Typen verarbeitet, die einem oder mehreren seiner Ziele bereitgestellt werden.

BroadcastBlock<T>

Stellt einen Puffer für das Speichern von höchstens einem Element gleichzeitig bereit und überschreibt jede Meldung mit dem Text, während sie eingeht.

BufferBlock<T>

Stellt einen Puffer zum Speichern von Daten für einen Dataflow bereit.

DataflowBlock

Stellt einen Satz mit statischen Methoden (Shared in Visual Basic) für die Arbeit mit bestimmten Datenflussblöcken bereit.

DataflowBlockOptions

Stellt Optionen bereit, mit denen die Verarbeitung konfiguriert wird, die von Datenflussblöcken ausgeführt wird.

DataflowLinkOptions

Stellt die Optionen bereit, die verwendet werden, um einen Link zwischen Datenflussblöcken zu konfigurieren.

ExecutionDataflowBlockOptions

Stellt Optionen bereit, die verwendet werden, um die Verarbeitung zu konfigurieren, die von Datenflussblöcken ausgeführt wird, die jede Meldung durch den Aufruf eines vom Benutzer bereitgestellten Delegaten verarbeiten. Dies sind Datenflussblöcke wie ActionBlock<TInput> und TransformBlock<TInput,TOutput>.

GroupingDataflowBlockOptions

Stellt Optionen bereit, die verwendet werden, um die Verarbeitung zu konfigurieren, die von Datenflussblöcken ausgeführt wird, die mehrere Nachrichten gruppieren. Dies sind Datenflussblöcke wie JoinBlock<T1,T2> und BatchBlock<T>.

JoinBlock<T1,T2>

Stellt einen Datenflussblock bereit, der sich über mehrere Datenflussquellen verbindet, nicht unbedingt desselben Typs, und wartet auf ein ankommendes Element für jeden Typ, bevor sie alle zusammen als Tupel freigegeben werden, das aus einem Element pro Typ besteht.

JoinBlock<T1,T2,T3>

Stellt einen Datenflussblock bereit, der sich über mehrere Datenflussquellen erstreckt, die nicht unbedingt desselben Typs sind. Der Datenflussblock wartet auf ein ankommendes Element für jeden Typ, bevor sie alle zusammen als Tupel freigegeben werden, das ein Element pro Typ enthält.

TransformBlock<TInput,TOutput>

Stellt einen Datenflussblock bereit, der einen bereitgestellten Func<T,TResult>-Delegaten für jede empfangene Datenelement aufruft.

TransformManyBlock<TInput,TOutput>

Stellt einen Datenflussblock bereit, der einen bereitgestellten Func<T,TResult>-Delegaten für jede empfangene Datenelement aufruft.

WriteOnceBlock<T>

Stellt einen Puffer für das Empfangen und Speichern von höchstens einem Element in einem Netzwerk von Datenflussblöcken bereit.

Strukturen

DataflowMessageHeader

Stellt einen Container mit Datenattributen für die Übergabe zwischen Datenflussblöcken bereit.

Schnittstellen

IDataflowBlock

Stellt einen Datenflussblock dar.

IPropagatorBlock<TInput,TOutput>

Stellt einen Datenflussblock dar, der ein Ziel für Daten und eine Quelle von Daten ist.

IReceivableSourceBlock<TOutput>

Stellt einen Datenflussblock dar, der das Empfangen von Meldungen unterstützt, ohne zu verknüpfen.

ISourceBlock<TOutput>

Stellt einen Datenflussblock dar, der eine Datenquelle darstellt.

ITargetBlock<TInput>

Stellt einen Datenflussblock dar, der ein Ziel für Daten ist.

Enumerationen

DataflowMessageStatus

Stellt den Status von einem DataflowMessageHeader bei der Übergabe zwischen Datenflussblöcken dar.

Hinweise

Hinweis

Die TPL-Datenflussbibliothek (System.Threading.Tasks.Dataflow-Namespace) wird nicht mit .NET ausgeliefert. Öffnen Sie zum Installieren des System.Threading.Tasks.Dataflow-Namespace in Visual Studio Ihr Projekt, wählen Sie im Menü Projekt die Option NuGet-Pakete verwalten aus, und suchen Sie online nach dem System.Threading.Tasks.Dataflow-Paket. Alternativ können Sie es mithilfe der .NET Core-CLI installieren und dazu dotnet add package System.Threading.Tasks.Dataflow ausführen.

Weitere Informationen finden Sie unter Datenfluss.