BatchedJoinBlock<T1,T2,T3> Klasse

Definition

Namespace:: System.Threading.Tasks.Dataflow

Assembly:: System.Threading.Tasks.Dataflow.dll

Paket:: System.Threading.Tasks.Dataflow v11.0.0-preview.4.26230.115

Quelle:: BatchedJoinBlock.cs

Quelle:: BatchedJoinBlock.cs

Quelle:: BatchedJoinBlock.cs

Quelle:: BatchedJoinBlock.cs

Quelle:: BatchedJoinBlock.cs

Quelle:: BatchedJoinBlock.cs

Quelle:: BatchedJoinBlock.cs

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 einen Datenflussblock bereit, der eine bestimmte Anzahl von Eingaben potenziell unterschiedlicher Typen angibt, die einem oder mehreren zielen zur Verfügung gestellt 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

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

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 Datentyp an, der vom ersten Ziel des Blocks akzeptiert wird.

T2

Gibt den Datentyp an, der vom zweiten Ziel des Blocks akzeptiert wird.

T3

Gibt den Datentyp an, der vom dritten Ziel des Blocks akzeptiert wird.

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

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.

Konstruktoren

Name	Beschreibung
BatchedJoinBlock<T1,T2,T3>(Int32, GroupingDataflowBlockOptions)	Initialisiert ein neues BatchedJoinBlock<T1,T2,T3> mit der angegebenen Konfiguration.
BatchedJoinBlock<T1,T2,T3>(Int32)	Initialisiert ein neues BatchedJoinBlock<T1,T2,T3> mit der angegebenen Konfiguration.

Eigenschaften

Name	Beschreibung
BatchSize	Ruft die Größe der von diesem BatchedJoinBlock<T1,T2,T3>generierten Batches ab.
Completion	Ruft einen Task , der den asynchronen Vorgang und den Abschluss des Datenflussblocks darstellt.
OutputCount	Ruft die Anzahl der Ausgabeelemente ab, die von diesem Block empfangen werden können.
Target1	Ruft ein Ziel ab, das verwendet werden kann, um Nachrichten vom ersten Typ anzubieten.
Target2	Ruft ein Ziel ab, das verwendet werden kann, um Nachrichten des zweiten Typs anzubieten.
Target3	Ruft ein Ziel ab, das verwendet werden kann, um Nachrichten des dritten Typs anzubieten.

Methoden

Name	Beschreibung
Complete()	Signalisiert, IDataflowBlock dass sie weder mehr Nachrichten akzeptieren noch mehr nachrichten produzieren sollte, noch mehr verschobene Nachrichten verbrauchen.
Equals(Object)	Bestimmt, ob das angegebene Objekt dem aktuellen Objekt entspricht. (Geerbt von Object)
GetHashCode()	Dient als Standardhashfunktion. (Geerbt von Object)
GetType()	Ruft die Type der aktuellen Instanz ab. (Geerbt von Object)
LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, DataflowLinkOptions)	Verknüpft den ISourceBlock<TOutput> angegebenen ITargetBlock<TInput> Wert.
MemberwiseClone()	Erstellt eine flache Kopie der 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, synchron ein verfügbares Ausgabeelement von der IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Versucht, alle verfügbaren Elemente synchron von der IReceivableSourceBlock<TOutput>.

Explizite Schnittstellenimplementierungen

Name	Beschreibung
IDataflowBlock.Fault(Exception)	Bewirkt, dass der IDataflowBlock Vorgang in einem Faulted Zustand abgeschlossen ist.
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 an die ITargetBlock<TInput>.
ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>)	Gibt das Recht frei, den Besitz der nachricht zu übergeben, die DataflowMessageHeader von dieser ISourceBlock<TOutput> an die ITargetBlock<TInput>.
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 nachricht zu übergeben, die DataflowMessageHeader von dieser ISourceBlock<TOutput> an die ITargetBlock<TInput>.

Erweiterungsmethoden

Name	Beschreibung
AsObservable<TOutput>(ISourceBlock<TOutput>)	Erstellt eine neue IObservable<T> Abstraktion über dem ISourceBlock<TOutput>.
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.
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.
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.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Versucht, ein Element synchron von der ISourceBlock<TOutput>.

Gilt für:

Feedback

War diese Seite hilfreich?