JoinBlock<T1,T2,T3> Klasa

Definicja

Przestrzeń nazw:

System.Threading.Tasks.Dataflow

Zestaw:

System.Threading.Tasks.Dataflow.dll

Pakiet:

System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

Źródło:

JoinBlock.cs

Udostępnia blok przepływu danych, który łączy się w wielu źródłach przepływu danych, które niekoniecznie są tego samego typu, czekając na nadejście jednego elementu dla każdego typu, zanim wszystkie zostaną wydane razem jako krotka zawierająca jeden element na typ.

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

public sealed class JoinBlock<T1,T2,T3> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<T1,T2,T3>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<T1,T2,T3>>

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

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

Parametry typu

T1

Określa typ danych akceptowanych przez pierwszy obiekt docelowy bloku.

T2

Określa typ danych akceptowanych przez drugi element docelowy bloku.

T3

Określa typ danych akceptowanych przez trzeci obiekt docelowy bloku.

Dziedziczenie

Object

JoinBlock<T1,T2,T3>

Implementuje

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

Uwagi

Uwaga

Biblioteka przepływu danych TPL ( System.Threading.Tasks.Dataflow przestrzeń nazw) nie jest dystrybuowana za pomocą platformy .NET. Aby zainstalować System.Threading.Tasks.Dataflow przestrzeń nazw w programie Visual Studio, otwórz projekt, wybierz pozycję Zarządzaj pakietami NuGet z menu Project i wyszukaj pakiet w trybie online System.Threading.Tasks.Dataflow . Alternatywnie, aby zainstalować go przy użyciu interfejsu wiersza polecenia platformy .NET Core, uruchom polecenie dotnet add package System.Threading.Tasks.Dataflow.

Konstruktory

JoinBlock<T1,T2,T3>()	Inicjuje nowy JoinBlock<T1,T2,T3>element .
JoinBlock<T1,T2,T3>(GroupingDataflowBlockOptions)	Inicjuje nowy JoinBlock<T1,T2,T3>element .

Właściwości

Completion	Pobiera element reprezentujący operację Task asynchroniczną i ukończenie bloku przepływu danych.
OutputCount	Pobiera liczbę dostępnych elementów wyjściowych do odebrania z tego bloku.
Target1	Pobiera element docelowy, który może służyć do oferowania komunikatów pierwszego typu.
Target2	Pobiera element docelowy, który może służyć do oferowania komunikatów drugiego typu.
Target3	Pobiera element docelowy, który może służyć do oferowania komunikatów trzeciego typu.

Metody

Complete()	Sygnały do IDataflowBlock tego, że nie powinny akceptować ani tworzyć więcej komunikatów, ani nie zużywać żadnych bardziej odroczonych komunikatów.
Equals(Object)	Określa, czy dany obiekt jest taki sam, jak bieżący obiekt. (Odziedziczone po Object)
GetHashCode()	Służy jako domyślna funkcja skrótu. (Odziedziczone po Object)
GetType()	Type Pobiera bieżące wystąpienie. (Odziedziczone po Object)
LinkTo(ITargetBlock<Tuple<T1,T2,T3>>, DataflowLinkOptions)	Łączy blok źródłowy z określonym blokiem docelowym.
MemberwiseClone()	Tworzy płytkią kopię bieżącego Objectelementu . (Odziedziczone po Object)
ToString()	Zwraca ciąg reprezentujący sformatowaną nazwę tego IDataflowBlock wystąpienia.
TryReceive(Predicate<Tuple<T1,T2,T3>>, Tuple<T1,T2,T3>)	Próbuje synchronicznie odebrać dostępny element wyjściowy z elementu IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<Tuple<T1,T2,T3>>)	Próbuje synchronicznie odebrać wszystkie dostępne elementy z elementu IReceivableSourceBlock<TOutput>.

Jawne implementacje interfejsu

IDataflowBlock.Fault(Exception)	IDataflowBlock Powoduje ukończenie Faulted operacji w stanie.
ISourceBlock<Tuple<T1,T2,T3>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<T1,T2,T3>>, Boolean)	Przekazuje własność komunikatu zidentyfikowanego przez DataflowMessageHeader wystąpienie z tego ISourceBlock<TOutput> wystąpienia do ITargetBlock<TInput>.
ISourceBlock<Tuple<T1,T2,T3>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<T1,T2,T3>>)	Zwalnia prawo do przekazania własności wiadomości zidentyfikowanej przez DataflowMessageHeader element z tego ISourceBlock<TOutput> do ITargetBlock<TInput>.
ISourceBlock<Tuple<T1,T2,T3>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<T1,T2,T3>>)	Zastrzega sobie prawo do przekazania własności wiadomości zidentyfikowanej przez DataflowMessageHeader element z tego ISourceBlock<TOutput> do ITargetBlock<TInput>.

Metody rozszerzania

AsObservable<TOutput>(ISourceBlock<TOutput>)	Tworzy nową IObservable<T> abstrakcję nad elementem ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput>elementem .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Task<TResult> Zapewnia, że asynchronicznie monitoruje źródło dostępnych danych wyjściowych.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Task<TResult> Zapewnia, że asynchronicznie monitoruje źródło dostępnych danych wyjściowych.
Receive<TOutput>(ISourceBlock<TOutput>)	Synchronicznie odbiera wartość z określonego źródła.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Synchronicznie odbiera wartość z określonego źródła i udostępnia token do anulowania operacji.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Synchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres przekroczenia limitu czasu.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Synchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału przekroczenia limitu czasu.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Tworzy obiekt IAsyncEnumerable<T> , który umożliwia odbieranie wszystkich danych ze źródła.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Asynchronicznie odbiera wartość z określonego źródła.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Asynchronicznie odbiera wartość z określonego źródła i udostępnia token do anulowania operacji.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Asynchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres przekroczenia limitu czasu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Asynchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału przekroczenia limitu czasu.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Próbuje synchronicznie odebrać element z elementu ISourceBlock<TOutput>.