BatchedJoinBlock<T1,T2,T3> Klasse

Definition

Namespace:

System.Threading.Tasks.Dataflow

Assembly:

System.Threading.Tasks.Dataflow.dll

Paket:

System.Threading.Tasks.Dataflow v9.0.0-rc.1.24431.7

Quelle:

BatchedJoinBlock.cs

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.

generic <typename T1, typename T2, typename T3>
public ref class BatchedJoinBlock sealed : System::Threading::Tasks::Dataflow::IReceivableSourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^, System::Collections::Generic::IList<T3> ^> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^, System::Collections::Generic::IList<T3> ^> ^>

public sealed class BatchedJoinBlock<T1,T2,T3> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>

type BatchedJoinBlock<'T1, 'T2, 'T3> = class
    interface IReceivableSourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
    interface ISourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
    interface IDataflowBlock

Public NotInheritable Class BatchedJoinBlock(Of T1, T2, T3)
Implements IReceivableSourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2), IList(Of T3))), ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2), IList(Of T3)))

Typparameter

T1

Gibt den Typ der Daten an, die vom ersten Ziel des Blocks akzeptiert werden.

T2

Gibt den Typ der Daten an, die vom zweiten Ziel des Blocks akzeptiert werden.

T3

Gibt den Typ der Daten an, die vom dritten Ziel des Blocks akzeptiert werden.

Vererbung

Object

BatchedJoinBlock<T1,T2,T3>

Implementiert

IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<TOutput>

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.

Konstruktoren

BatchedJoinBlock<T1,T2,T3>(Int32)	Initialisiert eine neue Instanz von BatchedJoinBlock<T1,T2,T3> mit der angegebenen Konfiguration.
BatchedJoinBlock<T1,T2,T3>(Int32, GroupingDataflowBlockOptions)	Initialisiert eine neue Instanz von BatchedJoinBlock<T1,T2,T3> mit der angegebenen Konfiguration.

Eigenschaften

BatchSize	Ruft die Größe der Batches ab, die von diesem BatchedJoinBlock<T1,T2,T3> generiert werden.
Completion	Ruft ein Task ab, das den asynchronen Vorgang und die Beendigung des Datenflussblocks darstellt.
OutputCount	Ruft die Anzahl der Ausgabe-Elementen ab, die von diesem Block empfangen werden können.
Target1	Ruft ein Ziel ab, das verwendet werden kann, um Meldungen des ersten Typs anzubieten.
Target2	Ruft ein Ziel ab, das verwendet werden kann, um Meldungen des zweiten Typs anzubieten.
Target3	Ruft ein Ziel ab, das verwendet werden kann, um Meldungen des dritten Typs anzubieten.

Methoden

Complete()	Signalisiert IDataflowBlock, dass es keine Nachrichten mehr akzeptieren und keine produzieren und keine weiteren zurückgestellten Nachrichten verarbeiten soll.
Equals(Object)	Bestimmt, ob das angegebene Objekt gleich dem aktuellen Objekt ist. (Geerbt von Object)
GetHashCode()	Fungiert als Standardhashfunktion. (Geerbt von Object)
GetType()	Ruft den Type der aktuellen Instanz ab. (Geerbt von Object)
LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, DataflowLinkOptions)	Verknüpft den mit ISourceBlock<TOutput> dem angegebenen ITargetBlock<TInput> .
MemberwiseClone()	Erstellt eine flache Kopie des aktuellen Object. (Geerbt von Object)
ToString()	Gibt eine Zeichenfolge zurück, die den formatierten Namen dieser IDataflowBlock-Instanz darstellt.
TryReceive(Predicate<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Tuple<IList<T1>,IList<T2>,IList<T3>>)	Versucht, ein verfügbares Output-Element vonIReceivableSourceBlock<TOutput> synchron zu empfangen.
TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Versucht, alle verfügbaren Elemente aus IReceivableSourceBlock<TOutput> synchron zu empfangen.

Explizite Schnittstellenimplementierungen

IDataflowBlock.Fault(Exception)	Bewirkt, IDataflowBlock in einem Faulted Zustand auszuführen.
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Boolean)	Übergibt den Besitz der nachricht, die DataflowMessageHeader von dieser ISourceBlock<TOutput> Instanz identifiziert wird, an die ITargetBlock<TInput>.
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Übergibt das Recht, den Besitz der durch die DataflowMessageHeader-Struktur identifizierten Nachricht von dieser ISourceBlock<TOutput> an die ITargetBlock<TInput>-Schnittstelle zu übergeben
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Behält sich das Recht vor, den Besitz der durch die DataflowMessageHeader-Struktur identifizierten Nachricht von dieser ISourceBlock<TOutput> an die ITargetBlock<TInput>-Schnittstelle zu übergeben

Erweiterungsmethoden

AsObservable<TOutput>(ISourceBlock<TOutput>)	Erstellt eine neue IObservable<T> Abstraktion über ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Verknüpft den mit ISourceBlock<TOutput> dem angegebenen ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Verknüpft den ISourceBlock<TOutput> mit dem angegebenen Filter mit dem angegebenen ITargetBlock<TInput> .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Verknüpft den ISourceBlock<TOutput> mit dem angegebenen Filter mit dem angegebenen ITargetBlock<TInput> .
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Stellt eine Task<TResult> bereit, die asynchron die Quelle für verfügbare Ausgabe überwacht.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Stellt eine Task<TResult> bereit, die asynchron die Quelle für verfügbare Ausgabe überwacht.
Receive<TOutput>(ISourceBlock<TOutput>)	Empfängt synchron einen Wert aus der angegebenen Quelle.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Erhält synchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um die Operation abzubrechen.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Empfängt synchron einen Wert aus einer angegebenen Quelle und beachtet ein optionales Timeout.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Empfängt synchron einen Wert aus einer angegebenen Quelle, stellt ein Token bereit, um den Vorgang abzubrechen und beachtet ein optionales Timeoutintervall.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Erstellt eine IAsyncEnumerable<T> , die den Empfang aller Daten aus der Quelle ermöglicht.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Empfängt asynchron einen Wert aus der angegebenen Quelle.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Erhält asynchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um die Operation abzubrechen.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Empfängt asynchron einen Wert aus einer angegebenen Quelle und beachtet ein optionales Timeout.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Empfängt asynchron einen Wert aus einer angegebenen Quelle, stellt ein Token bereit, um den Vorgang abzubrechen und beachtet ein optionales Timeoutintervall.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Versucht, ein Element von ISourceBlock<TOutput> synchron zu empfangen.