BatchedJoinBlock<T1,T2,T3> Sınıf
Tanım
Önemli
Bazı bilgiler ürünün ön sürümüyle ilgilidir ve sürüm öncesinde önemli değişiklikler yapılmış olabilir. Burada verilen bilgilerle ilgili olarak Microsoft açık veya zımni hiçbir garanti vermez.
Bir veya daha fazla hedefine sağlanan, belirli sayıda farklı türde girişi toplu hale getiren bir veri akışı bloğu sağlar.
generic <typename T1, typename T2, typename T3>
public ref class BatchedJoinBlock sealed : System::Threading::Tasks::Dataflow::IReceivableSourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^, System::Collections::Generic::IList<T3> ^> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^, System::Collections::Generic::IList<T3> ^> ^>public sealed class BatchedJoinBlock<T1,T2,T3> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>,System.Collections.Generic.IList<T3>>>type BatchedJoinBlock<'T1, 'T2, 'T3> = class
interface IReceivableSourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
interface ISourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
interface IDataflowBlocktype BatchedJoinBlock<'T1, 'T2, 'T3> = class
interface IDataflowBlock
interface IReceivableSourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>
interface ISourceBlock<IList<'T1> * IList<'T2> * IList<'T3>>Public NotInheritable Class BatchedJoinBlock(Of T1, T2, T3)
Implements IReceivableSourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2), IList(Of T3))), ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2), IList(Of T3)))Tür Parametreleri
- T1
Bloğun ilk hedefi tarafından kabul edilen veri türünü belirtir.
- T2
Bloğun ikinci hedefi tarafından kabul edilen veri türünü belirtir.
- T3
Bloğun üçüncü hedefi tarafından kabul edilen veri türünü belirtir.
- Devralma
-
BatchedJoinBlock<T1,T2,T3>
- Uygulamalar
-
IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>> ISourceBlock<TOutput>
Açıklamalar
Not
TPL veri akışı kitaplığı ( System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. System.Threading.Tasks.DataflowVisual Studio 'da ad alanını yüklemek için projenizi açın, Proje menüsünden NuGet Paketlerini Yönet ' i seçin ve paketi çevrimiçi olarak arayın System.Threading.Tasks.Dataflow . Alternatif olarak, .NET Core CLIkullanarak yüklemek için öğesini çalıştırın dotnet add package System.Threading.Tasks.Dataflow .
Oluşturucular
| BatchedJoinBlock<T1,T2,T3>(Int32) |
Belirtilen yapılandırmayla yeni BatchedJoinBlock<T1,T2,T3> bir başlatır. |
| BatchedJoinBlock<T1,T2,T3>(Int32, GroupingDataflowBlockOptions) |
Belirtilen yapılandırmayla yeni BatchedJoinBlock<T1,T2,T3> bir başlatır. |
Özellikler
| BatchSize |
Bu BatchedJoinBlock<T1,T2,T3>tarafından oluşturulan toplu iş boyutlarını alır. |
| Completion |
Zaman uyumsuz işlemi ve veri akışı bloğunun tamamlanmasını temsil eden bir Task alır. |
| OutputCount |
Bu bloktan alınabilecek çıkış öğelerinin sayısını alır. |
| Target1 |
İlk türdeki iletileri sunmak için kullanılabilecek bir hedef alır. |
| Target2 |
İkinci türdeki iletileri sunmak için kullanılabilecek bir hedef alır. |
| Target3 |
Üçüncü türdeki iletileri sunmak için kullanılabilecek bir hedef alır. |
Yöntemler
| Complete() |
IDataflowBlock Kabul edilmemesi, daha fazla ileti üretilmemesi veya ertelenmiş iletilerin tüketilmemesi gerektiğine dair sinyaller. |
| Equals(Object) |
Belirtilen nesnenin geçerli nesneye eşit olup olmadığını belirler. (Devralındığı yer: Object) |
| GetHashCode() |
Varsayılan karma işlevi işlevi görür. (Devralındığı yer: Object) |
| GetType() |
Type Geçerli örneğini alır. (Devralındığı yer: Object) |
| LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, DataflowLinkOptions) |
öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput> öğesine bağlar. |
| MemberwiseClone() |
Geçerli Objectöğesinin sığ bir kopyasını oluşturur. (Devralındığı yer: Object) |
| ToString() |
Bu IDataflowBlock örneğin biçimlendirilmiş adını temsil eden bir dize döndürür. |
| TryReceive(Predicate<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Tuple<IList<T1>,IList<T2>,IList<T3>>) |
öğesinden IReceivableSourceBlock<TOutput>zaman uyumlu olarak kullanılabilir bir çıkış öğesi almaya çalışır. |
| TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>,IList<T3>>>) |
öğesinden IReceivableSourceBlock<TOutput>tüm kullanılabilir öğeleri zaman uyumlu olarak almaya çalışır. |
Belirtik Arabirim Kullanımları
| IDataflowBlock.Fault(Exception) |
durumunda IDataflowBlock tamamlanmasına Faulted neden olur. |
| ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>, Boolean) |
tarafından tanımlanan DataflowMessageHeader iletinin sahipliğini bu ISourceBlock<TOutput> örnekten öğesine ITargetBlock<TInput>geçirir. |
| ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>) |
tarafından tanımlanan DataflowMessageHeader iletinin sahipliğini buradan ISourceBlock<TOutput> ITargetBlock<TInput>öğesine geçirme hakkını serbest bırakır. |
| ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ReserveMessage(DataflowMessageHeader, ITargetBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>) |
tarafından tanımlanan DataflowMessageHeader iletinin sahipliğini buradan ISourceBlock<TOutput> ITargetBlock<TInput>öğesine geçirme hakkını saklıdır. |
Uzantı Metotları
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
üzerinde ISourceBlock<TOutput>yeni IObservable<T> bir soyutlama oluşturur. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Belirtilen kaynaktan zaman uyumlu olarak bir değer alır. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Belirtilen kaynaktan zaman uyumlu olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Belirli bir kaynaktan isteğe bağlı bir zaman aşımı süresini gözlemleyerek zaman uyumlu olarak bir değer alır. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Belirtilen kaynaktan zaman uyumlu olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığını gözlemler. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Kaynaktan tüm verilerin alınmasını sağlayan bir IAsyncEnumerable<T> oluşturur. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve isteğe bağlı bir zaman aşımı süresini gözlemler. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığını gözlemler. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
öğesinden ISourceBlock<TOutput>bir öğeyi zaman uyumlu olarak almaya çalışır. |