BroadcastBlock<T> 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 kerede en fazla bir öğeyi depolamak için bir arabellek sağlar ve her ileti geldikçe sonraki iletinin üzerine yazılır.
generic <typename T>
public ref class BroadcastBlock sealed : 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>public sealed class BroadcastBlock<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 BroadcastBlock<'T> = class
interface IPropagatorBlock<'T, 'T>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T>
interface IReceivableSourceBlock<'T>type BroadcastBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T>
interface ISourceBlock<'T>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T>Public NotInheritable Class BroadcastBlock(Of T)
Implements IPropagatorBlock(Of T, T), IReceivableSourceBlock(Of T), ISourceBlock(Of T), ITargetBlock(Of T)Tür Parametreleri
- T
Bu veri akışı bloğu tarafından arabelleğe alınan verilerin türünü belirtir.
- Devralma
-
BroadcastBlock<T>
- Uygulamalar
Açıklamalar
Not
TPL Veri Akışı Kitaplığı ( System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. Ad alanını System.Threading.Tasks.Dataflow Visual Studio'ya yüklemek için projenizi açın, Projemenüsünden NuGet Paketlerini Yönet'i seçin ve çevrimiçi ortamda System.Threading.Tasks.Dataflow paketi arayın. Alternatif olarak, .NET Core CLI kullanarak yüklemek için komutunu çalıştırın dotnet add package System.Threading.Tasks.Dataflow.
BroadcastBlock<T> bir kerede en fazla bir öğeyi kullanıma sunar. Ancak, bloğuna yeni öğeler sağlandığından, öğesinden farklı WriteOnceBlock<T>olarak bu öğenin üzerine yazılır. BroadcastBlock<T> öğenin üzerine yazılmasını sağlamadan önce geçerli öğenin bağlı hedeflere yayınlanmasını sağlar.
Oluşturucular
| BroadcastBlock<T>(Func<T,T>) |
belirtilen kopyalama işleviyle öğesini BroadcastBlock<T> başlatır. |
| BroadcastBlock<T>(Func<T,T>, DataflowBlockOptions) |
belirtilen kopyalama işlevi ve DataflowBlockOptionsile öğesini BroadcastBlock<T> başlatır. |
Özellikler
| Completion |
Zaman uyumsuz işlemi ve veri akışı bloğunun tamamlanmasını temsil eden bir Task 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<T>, 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<T>, T) |
öğesinden IReceivableSourceBlock<TOutput>zaman uyumlu olarak kullanılabilir bir çıkış öğesi almaya çalışır. |
Belirtik Arabirim Kullanımları
Uzantı Metotları
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
üzerinde ISourceBlock<TOutput>yeni IObservable<T> bir soyutlama oluşturur. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
üzerinde ITargetBlock<TInput>yeni IObserver<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. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Öğesine bir öğe postalar ITargetBlock<TInput>. |
| 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. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Zaman uyumsuz olarak hedef ileti bloğuna bir ileti seçerek ertelemeye olanak tanır. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Zaman uyumsuz olarak hedef ileti bloğuna bir ileti seçerek ertelemeye olanak tanır. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
öğesinden ISourceBlock<TOutput>bir öğeyi zaman uyumlu olarak almaya çalışır. |
