BatchedJoinBlock<T1,T2> クラス

定義

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 番目のターゲットが受け入れるデータの種類を指定します。

継承
BatchedJoinBlock<T1,T2>
実装

注釈

Note

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, GroupingDataflowBlockOptions)

指定した構成で新しい BatchedJoinBlock<T1,T2> を初期化します。

BatchedJoinBlock<T1,T2>(Int32)

指定した構成で新しい 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)

指定したISourceBlock<TOutput>ITargetBlock<TInput>をリンクします。

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)

IDataflowBlockFaulted状態で完了します。

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>, DataflowLinkOptions, Predicate<TOutput>)

指定したフィルターを使用して、指定したISourceBlock<TOutput>ITargetBlock<TInput>をリンクします。

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

指定したフィルターを使用して、指定したISourceBlock<TOutput>ITargetBlock<TInput>をリンクします。

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

指定したISourceBlock<TOutput>ITargetBlock<TInput>をリンクします。

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

ソースで使用可能な出力を非同期的に監視する Task<TResult> を提供します。

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

ソースで使用可能な出力を非同期的に監視する Task<TResult> を提供します。

Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

指定したソースから値を同期的に受信し、操作を取り消すトークンを提供します。

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

指定したソースから値を同期的に受信し、操作を取り消すトークンを提供し、オプションのタイムアウト間隔を監視します。

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

指定したソースから値を同期的に受信し、オプションのタイムアウト期間を監視します。

Receive<TOutput>(ISourceBlock<TOutput>)

指定したソースから値を同期的に受信します。

ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)

ソースからすべてのデータを受信できるようにする IAsyncEnumerable<T> を作成します。

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

指定したソースから値を非同期に受信し、操作を取り消すトークンを提供します。

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

指定したソースから値を非同期に受信し、操作を取り消すトークンを提供し、オプションのタイムアウト間隔を監視します。

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

指定したソースから値を非同期に受信し、オプションのタイムアウト期間を監視します。

ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

指定したソースから値を非同期的に受信します。

TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

ISourceBlock<TOutput>からアイテムを同期的に受信しようとします。

適用対象