BatchedJoinBlock<T1,T2> Kelas

Definisi

Ruang nama:: System.Threading.Tasks.Dataflow

Rakitan:: System.Threading.Tasks.Dataflow.dll

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

Sumber:: BatchedJoinBlock.cs

Sumber:: BatchedJoinBlock.cs

Sumber:: BatchedJoinBlock.cs

Sumber:: BatchedJoinBlock.cs

Sumber:: BatchedJoinBlock.cs

Sumber:: BatchedJoinBlock.cs

Sumber:: BatchedJoinBlock.cs

Penting

Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.

Menyediakan blok aliran data yang mengumpulkan sejumlah input tertentu dari jenis yang berpotensi berbeda yang disediakan untuk satu atau beberapa targetnya.

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

Jenis parameter

T1

Menentukan jenis data yang diterima oleh target pertama blok.

T2

Menentukan jenis data yang diterima oleh target kedua blok.

Warisan: Object
BatchedJoinBlock<T1,T2>

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

Keterangan

Note

Pustaka Aliran Data TPL (namespace System.Threading.Tasks.Dataflow) tidak didistribusikan dengan .NET. Untuk menginstal namespace System.Threading.Tasks.Dataflow di Visual Studio, buka proyek Anda, pilih Kelola Paket NuGet dari menu Project, dan cari paket System.Threading.Tasks.Dataflow secara online. Atau, untuk menginstalnya menggunakan .NET Core CLI , jalankan dotnet add package System.Threading.Tasks.Dataflow.

Konstruktor

Nama	Deskripsi
BatchedJoinBlock<T1,T2>(Int32, GroupingDataflowBlockOptions)	Menginisialisasi baru BatchedJoinBlock<T1,T2> dengan konfigurasi yang ditentukan.
BatchedJoinBlock<T1,T2>(Int32)	Menginisialisasi baru BatchedJoinBlock<T1,T2> dengan konfigurasi yang ditentukan.

Properti

Nama	Deskripsi
BatchSize	Mendapatkan ukuran batch yang dihasilkan oleh .BatchedJoinBlock<T1,T2>
Completion	Task Mendapatkan yang mewakili operasi asinkron dan penyelesaian blok aliran data.
OutputCount	Mendapatkan jumlah item output yang tersedia untuk diterima dari blok ini.
Target1	Mendapatkan target yang dapat digunakan untuk menawarkan pesan jenis pertama.
Target2	Mendapatkan target yang dapat digunakan untuk menawarkan pesan jenis kedua.

Metode

Nama	Deskripsi
Complete()	Sinyal kepada IDataflowBlock bahwa ia tidak boleh menerima atau menghasilkan pesan lagi atau mengonsumsi pesan yang ditunda lagi.
Equals(Object)	Menentukan apakah objek yang ditentukan sama dengan objek saat ini. (Diperoleh dari Object)
GetHashCode()	Berfungsi sebagai fungsi hash default. (Diperoleh dari Object)
GetType()	Mendapatkan Type instans saat ini. (Diperoleh dari Object)
LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>>>, DataflowLinkOptions)	Menautkan ISourceBlock<TOutput> ke ITargetBlock<TInput> .
MemberwiseClone()	Membuat salinan dangkal dari Objectsaat ini. (Diperoleh dari Object)
ToString()	Mengembalikan string yang mewakili nama yang diformat dari instans ini IDataflowBlock .
TryReceive(Predicate<Tuple<IList<T1>,IList<T2>>>, Tuple<IList<T1>,IList<T2>>)	Mencoba untuk secara sinkron menerima item output yang tersedia dari IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>>>)	Upaya untuk menerima semua item yang tersedia secara sinkron dari IReceivableSourceBlock<TOutput>.

Implementasi Antarmuka Eksplisit

Nama	Deskripsi
IDataflowBlock.Fault(Exception)	Menyebabkan selesai IDataflowBlock dalam keadaan Faulted .
ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>, Boolean)	Meneruskan kepemilikan pesan yang diidentifikasi oleh DataflowMessageHeader dari instans ini ISourceBlock<TOutput> ke ITargetBlock<TInput>.
ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>)	Melepaskan hak untuk meneruskan kepemilikan pesan yang diidentifikasi oleh DataflowMessageHeader dari ini ISourceBlock<TOutput> ke ITargetBlock<TInput>.
ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>>>)	Berhak untuk meneruskan kepemilikan pesan yang diidentifikasi oleh DataflowMessageHeader dari ini ISourceBlock<TOutput> ke ITargetBlock<TInput>.

Metode Ekstensi

Nama	Deskripsi
AsObservable<TOutput>(ISourceBlock<TOutput>)	Membuat abstraksi baru IObservable<T> melalui ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput> menggunakan filter yang ditentukan.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput> menggunakan filter yang ditentukan.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Menautkan ISourceBlock<TOutput> ke ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Menyediakan yang secara asinkron memantau sumber untuk output yang Task<TResult> tersedia.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Menyediakan yang secara asinkron memantau sumber untuk output yang Task<TResult> tersedia.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Secara sinkron menerima nilai dari sumber tertentu dan menyediakan token untuk membatalkan operasi.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Secara sinkron menerima nilai dari sumber tertentu, menyediakan token untuk membatalkan operasi dan mengamati interval batas waktu opsional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Secara sinkron menerima nilai dari sumber tertentu, mengamati periode waktu habis opsional.
Receive<TOutput>(ISourceBlock<TOutput>)	Secara sinkron menerima nilai dari sumber tertentu.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Membuat yang IAsyncEnumerable<T> memungkinkan penerimaan semua data dari sumber.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Secara asinkron menerima nilai dari sumber tertentu dan menyediakan token untuk membatalkan operasi.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Secara asinkron menerima nilai dari sumber tertentu, menyediakan token untuk membatalkan operasi dan mengamati interval waktu habis opsional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Secara asinkron menerima nilai dari sumber tertentu, mengamati periode waktu habis opsional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Secara asinkron menerima nilai dari sumber tertentu.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Mencoba untuk menerima item secara sinkron dari ISourceBlock<TOutput>.

Berlaku untuk

Saran dan Komentar

Apakah halaman ini membantu?