BatchedJoinBlock<T1,T2> Kelas

Definisi

Ruang nama:

System.Threading.Tasks.Dataflow

Rakitan:

System.Threading.Tasks.Dataflow.dll

Paket:

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

Sumber:

BatchedJoinBlock.cs

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

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

Catatan

Pustaka Aliran Data TPL (namespace layanan System.Threading.Tasks.Dataflow) tidak didistribusikan dengan .NET. Untuk menginstal namespace layanan System.Threading.Tasks.Dataflow di Visual Studio, buka proyek, pilih Kelola Paket NuGet dari menu Proyek, 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

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

Properti

BatchSize	Mendapatkan ukuran batch yang dihasilkan oleh ini 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

Complete()	Sinyal untuk IDataflowBlock yang seharusnya tidak diterima atau menghasilkan pesan lagi atau mengkonsumsi 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 dari instans Type saat ini. (Diperoleh dari Object)
LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>>>, DataflowLinkOptions)	Menautkan ke ISourceBlock<TOutput> yang ditentukan ITargetBlock<TInput> .
MemberwiseClone()	Membuat salinan dangkal dari saat ini Object. (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>>)	Upaya untuk menerima item output yang tersedia secara sinkron 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

IDataflowBlock.Fault(Exception)	IDataflowBlock Menyebabkan selesai dalam keadaanFaulted.
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

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