BatchedJoinBlock<T1,T2> クラス

リファレンス

定義

名前空間:: System.Threading.Tasks.Dataflow

アセンブリ:: System.Threading.Tasks.Dataflow.dll

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

1 つ以上のターゲットに適用された、型が異なる可能性のある指定された数の入力をバッチ処理するデータフローブロックを提供します。

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

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

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

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

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

型パラメーター

T1

ブロックの最初のターゲットが受け取るデータの種類を指定します。

T2

ブロックの 2 番目のターゲットが受け取るデータの種類を指定します。

継承: Object
BatchedJoinBlock<T1,T2>

実装: IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>>> ISourceBlock<Tuple<IList<T1>,IList<T2>>> ISourceBlock<TOutput>

注釈

注意

TPL データフローライブラリ (System.Threading.Tasks.Dataflow 名前空間) は、.NET と一緒には配布されません。 Visual Studio に System.Threading.Tasks.Dataflow 名前空間をインストールするには、プロジェクトを開き、 [プロジェクト] メニューの [NuGet パッケージの管理] をクリックし、System.Threading.Tasks.Dataflow パッケージをオンラインで検索します。または、.NET Core CLI を使ってインストールするには、dotnet add package System.Threading.Tasks.Dataflow を実行します。

コンストラクター

BatchedJoinBlock<T1,T2>(Int32)	指定した構成を使用して、BatchedJoinBlock<T1,T2> の新しいインスタンスを初期化します。
BatchedJoinBlock<T1,T2>(Int32, GroupingDataflowBlockOptions)	指定した構成を使用して、BatchedJoinBlock<T1,T2> の新しいインスタンスを初期化します。

プロパティ

BatchSize	この BatchedJoinBlock<T1,T2> によって生成されたバッチのサイズを取得します。
Completion	データフローブロックの非同期操作と完了を表す Task を取得します。
OutputCount	このブロックから取得できる出力項目の数を取得します。
Target1	最初の型のメッセージを提供するために使用できるターゲットを取得します。
Target2	2 番目の型のメッセージを提供するために使用できるターゲットを取得します。

メソッド

Complete()	これ以上メッセージを受け付けまたは生成せず、延期メッセージを使用しないことを IDataflowBlock に通知します。
Equals(Object)	指定されたオブジェクトが現在のオブジェクトと等しいかどうかを判断します。 (継承元 Object)
GetHashCode()	既定のハッシュ関数として機能します。 (継承元 Object)
GetType()	現在のインスタンスの Type を取得します。 (継承元 Object)
LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>>>, DataflowLinkOptions)	指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
MemberwiseClone()	現在の Object の簡易コピーを作成します。 (継承元 Object)
ToString()	この IDataflowBlock インスタンスの書式設定された名前を表す文字列を返します。
TryReceive(Predicate<Tuple<IList<T1>,IList<T2>>>, Tuple<IList<T1>,IList<T2>>)	使用可能な出力項目を IReceivableSourceBlock<TOutput> から同期的に受け取ろうとします。
TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>>>)	使用可能なすべての項目を IReceivableSourceBlock<TOutput> から同期的に受け取ろうとします。

明示的なインターフェイスの実装

IDataflowBlock.Fault(Exception)	IDataflowBlock を Faulted 状態で完了するようにします。
ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>, Boolean)	DataflowMessageHeader によって識別されるメッセージの所有権をこの ISourceBlock<TOutput> インスタンスから ITargetBlock<TInput> に渡します。
ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>)	権利を解放して、DataflowMessageHeader によって識別されるメッセージの所有権をこの ISourceBlock<TOutput> から ITargetBlock<TInput> に渡します。
ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>)	権利を予約して、DataflowMessageHeader によって識別されるメッセージの所有権をこの ISourceBlock<TOutput> から ITargetBlock<TInput> に渡します。

拡張メソッド

AsObservable<TOutput>(ISourceBlock<TOutput>)	IObservable<T> の新しい ISourceBlock<TOutput> 抽象化を作成します。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	指定したフィルターを使用して、指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	指定したフィルターを使用して、指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	使用できる出力のソースを非同期的に監視する Task<TResult> を提供します。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	使用できる出力のソースを非同期的に監視する Task<TResult> を提供します。
Receive<TOutput>(ISourceBlock<TOutput>)	指定されたソースから値を同期的に受信します。
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	同期的に指定したソースから値を受け取り、操作をキャンセルするトークンを提供します。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	同期的に指定したソースから値を受信し、オプションのタイムアウト期間を確認します。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	同期的に操作をキャンセルするトークンを提供し、オプションのタイムアウト間隔を確認する指定したソースから値を受け取ります。
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	IAsyncEnumerable<T>ソースからすべてのデータを受信できるようにするオブジェクトを作成します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	指定されたソースから値を非同期的に受信します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	非同期に指定したソースから値を受け取り、操作をキャンセルするトークンを提供します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	非同期に指定したソースから値を受信し、オプションのタイムアウト期間を確認します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	非同期に操作をキャンセルするトークンを提供し、オプションのタイムアウト間隔を確認する指定したソースから値を受け取ります。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	ISourceBlock<TOutput> から使用可能な出力項目を同期的に受信します。

適用対象

次の方法で共有