DataflowBlock Klasse
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Stellt eine Reihe statischer Methoden (Shared in Visual Basic) zum Arbeiten mit Datenflussblöcken bereit.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Vererbung
-
DataflowBlock
Hinweise
Note
Die TPL Dataflow Library (der System.Threading.Tasks.Dataflow Namespace) wird nicht mit .NET verteilt. Um den System.Threading.Tasks.Dataflow Namespace in Visual Studio zu installieren, öffnen Sie Ihr Projekt, wählen Sie "NuGet-Pakete verwalten " im Menü "Projekt " aus, und suchen Sie online nach dem System.Threading.Tasks.Dataflow Paket. Führen Sie alternativ das .NET Core CLI aus, um es zu installieren, indem Sie dotnet add package System.Threading.Tasks.Dataflow ausführen.
Methoden
| Name | Beschreibung |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Erstellt eine neue IObservable<T> Abstraktion über dem ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Erstellt eine neue IObserver<T> Abstraktion über dem ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Überwacht drei Datenquellen und ruft den bereitgestellten Handler für die datenquelle zuerst zur Verfügung. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Überwacht drei Datenquellen und ruft den bereitgestellten Handler für die datenquelle zuerst zur Verfügung. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Überwacht zwei Datenquellen und ruft den bereitgestellten Handler für welche Quelle zuerst Daten zur Verfügung stellt. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Überwacht zwei Datenquellen und ruft den bereitgestellten Handler für welche Quelle zuerst Daten zur Verfügung stellt. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Kapselt ein Ziel und eine Quelle in einen einzelnen Verteilungsmodul. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Verknüpft den ISourceBlock<TOutput> angegebenen Filter mit dem angegebenen ITargetBlock<TInput> Filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Verknüpft den ISourceBlock<TOutput> angegebenen Filter mit dem angegebenen ITargetBlock<TInput> Filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Verknüpft den ISourceBlock<TOutput> angegebenen ITargetBlock<TInput>Wert. |
| NullTarget<TInput>() |
Ruft einen Zielblock ab, der alle darin angebotenen Nachrichten synchron akzeptiert und abbricht. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Stellt eine Bereit Task<TResult> , die die Quelle asynchron auf die verfügbare Ausgabe überwacht. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Stellt eine Bereit Task<TResult> , die die Quelle asynchron auf die verfügbare Ausgabe überwacht. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Stellt ein Element in das ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Empfängt synchron einen Wert aus einer angegebenen Quelle und stellt ein Token zum Abbrechen des Vorgangs bereit. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Empfängt synchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um den Vorgang abzubrechen und ein optionales Timeoutintervall zu beobachten. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Empfängt synchron einen Wert aus einer angegebenen Quelle, wobei ein optionaler Timeoutzeitraum beobachtet wird. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Empfängt synchron einen Wert aus einer angegebenen Quelle. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Erstellt eine IAsyncEnumerable<T> , die das Empfangen aller Daten aus der Quelle ermöglicht. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Empfängt asynchron einen Wert aus einer angegebenen Quelle und stellt ein Token zum Abbrechen des Vorgangs bereit. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Empfängt asynchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um den Vorgang abzubrechen und ein optionales Timeoutintervall zu beobachten. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Empfängt asynchron einen Wert aus einer angegebenen Quelle, wobei ein optionaler Timeoutzeitraum beobachtet wird. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Empfängt asynchron einen Wert aus einer angegebenen Quelle. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Bietet asynchron eine Nachricht an den Zielnachrichtenblock, sodass eine Verschiebung möglich ist. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Bietet asynchron eine Nachricht an den Zielnachrichtenblock, sodass eine Verschiebung möglich ist. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Versucht, ein Element synchron von der ISourceBlock<TOutput>. |
