BatchBlock<T> クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
入力を配列にバッチ処理するデータフロー ブロックを提供します。
generic <typename T>
public ref class BatchBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, cli::array <T> ^>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ITargetBlock<T>
public sealed class BatchBlock<T> : System.Threading.Tasks.Dataflow.IPropagatorBlock<T,T[]>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<T[]>, System.Threading.Tasks.Dataflow.ISourceBlock<T[]>, System.Threading.Tasks.Dataflow.ITargetBlock<T>
type BatchBlock<'T> = class
interface IPropagatorBlock<'T, 'T[]>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T[]>
interface IReceivableSourceBlock<'T[]>
type BatchBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T[]>
interface ISourceBlock<'T[]>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T[]>
Public NotInheritable Class BatchBlock(Of T)
Implements IPropagatorBlock(Of T, T()), IReceivableSourceBlock(Of T()), ISourceBlock(Of T()), ITargetBlock(Of T)
型パラメーター
- T
バッチに入力されたデータの種類を指定します。
- 継承
-
BatchBlock<T>
- 実装
注釈
注意
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
を実行します。
コンストラクター
BatchBlock<T>(Int32) |
指定バッチ サイズを使用して BatchBlock<T> の新しいインスタンスを初期化します。 |
BatchBlock<T>(Int32, GroupingDataflowBlockOptions) |
指定したバッチ サイズ、拒否オプション、およびブロック オプションを使用して、新しい BatchBlock<T> を初期化します。 |
プロパティ
BatchSize |
この BatchBlock<T> によって生成されたバッチのサイズを取得します。 |
Completion |
データ フロー ブロックの非同期操作と完了を表す Task を取得します。 |
OutputCount |
このブロックから取得できる出力項目の数を取得します。 |
メソッド
Complete() |
これ以上メッセージを受け付けまたは生成せず、延期メッセージを使用しないことを IDataflowBlock に通知します。 |
Equals(Object) |
指定されたオブジェクトが現在のオブジェクトと等しいかどうかを判断します。 (継承元 Object) |
GetHashCode() |
既定のハッシュ関数として機能します。 (継承元 Object) |
GetType() |
現在のインスタンスの Type を取得します。 (継承元 Object) |
LinkTo(ITargetBlock<T[]>, DataflowLinkOptions) |
を ISourceBlock<TOutput> 指定した にリンクします ITargetBlock<TInput> 。 |
MemberwiseClone() |
現在の Object の簡易コピーを作成します。 (継承元 Object) |
ToString() |
この IDataflowBlock インスタンスの書式設定された名前を表す文字列を返します。 |
TriggerBatch() |
現在キューにあるか、または延期された項目の数が BatchBlock<T> より小さい場合でも、BatchSize をトリガーしてバッチ処理操作を開始します。 |
TryReceive(Predicate<T[]>, T[]) |
使用可能な出力項目を IReceivableSourceBlock<TOutput> から同期的に受け取ろうとします。 |
TryReceiveAll(IList<T[]>) |
使用可能なすべての項目を IReceivableSourceBlock<TOutput> から同期的に受け取ろうとします。 |
明示的なインターフェイスの実装
IDataflowBlock.Fault(Exception) |
IDataflowBlock を Faulted 状態で完了するようにします。 |
ISourceBlock<T[]>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T[]>, Boolean) |
前にこの ISourceBlock<TOutput> によって提供された DataflowMessageHeader を受け入れて使用するために、リンクされた ITargetBlock<TInput> によって呼び出されます。 |
ISourceBlock<T[]>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T[]>) |
この ITargetBlock<TInput> によって前に予約された DataflowMessageHeader を解放するために、リンクされた ISourceBlock<TOutput> によって呼び出されます。 |
ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T[]>) |
この ITargetBlock<TInput> によって前に提供された DataflowMessageHeader を予約するために、リンクされた ISourceBlock<TOutput> によって呼び出されます。 |
ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean) |
メッセージを ITargetBlock<TInput> に提供し、メッセージを使用または延期する機会をターゲットに与えます。 |
拡張メソッド
適用対象
.NET