Aracılığıyla paylaş


System.Threading.Tasks.Dataflow Ad Alanı

, Kaba veri akışı ve ardışık düzen görevleri için işlem içi ileti geçişini destekleyen aktör tabanlı bir programlama modeli sağlar.

Sınıflar

ActionBlock<TInput>

Alınan her veri öğesi için sağlanan Action<T> bir temsilciyi çağıran bir veri akışı bloğu sağlar.

BatchBlock<T>

Girişleri dizilere dönüştüren bir veri akışı bloğu sağlar.

BatchedJoinBlock<T1,T2>

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.

BatchedJoinBlock<T1,T2,T3>

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.

BroadcastBlock<T>

Bir kerede en fazla bir öğeyi depolamak için bir arabellek sağlar ve her ileti geldikçe sonraki iletinin üzerine yazılır.

BufferBlock<T>

Veri Akışı için verileri depolamak için bir arabellek sağlar.

DataflowBlock

Veri akışı bloklarıyla çalışmak için bir dizi statik (Visual Basic paylaşılan) yöntem sağlar.

DataflowBlockOptions

Veri akışı blokları tarafından gerçekleştirilen işlemeyi yapılandırmak için kullanılan seçenekleri sağlar.

DataflowLinkOptions

Veri akışı blokları arasında bağlantı yapılandırmak için kullanılan seçenekleri sağlar.

ExecutionDataflowBlockOptions

Kullanıcı tarafından sağlanan bir temsilcinin çağrısıyla her iletiyi işleyen veri akışı blokları tarafından gerçekleştirilen işlemeyi yapılandırmak için kullanılan seçenekleri sağlar. Bunlar ve TransformBlock<TInput,TOutput>gibi ActionBlock<TInput> veri akışı bloklarıdır.

GroupingDataflowBlockOptions

Birden çok iletiyi birlikte gruplandıran veri akışı blokları tarafından gerçekleştirilen işlemeyi yapılandırmak için kullanılan seçenekleri sağlar. Bunlar ve BatchBlock<T>gibi JoinBlock<T1,T2> veri akışı bloklarıdır.

JoinBlock<T1,T2>

Birden çok veri akışı kaynağı arasında birleştiren bir veri akışı bloğu sağlar; aynı türe sahip olması gerekmez ve her tür için bir öğenin, her tür için tek bir öğeden oluşan bir tanımlama grubu olarak birlikte yayımlanmadan önce gelmesini bekler.

JoinBlock<T1,T2,T3>

Birden çok veri akışı kaynağı arasında bir araya gelen ve aynı türde olması gerekmeyen bir veri akışı bloğu sağlar ve her tür için tek bir öğenin, her tür için tek bir öğe içeren bir tanımlama grubu olarak birlikte yayımlanmadan önce gelmesini bekler.

TransformBlock<TInput,TOutput>

Alınan her veri öğesi için sağlanan Func<T,TResult> bir temsilciyi çağıran bir veri akışı bloğu sağlar.

TransformManyBlock<TInput,TOutput>

Alınan her veri öğesi için sağlanan Func<T,TResult> bir temsilciyi çağıran bir veri akışı bloğu sağlar.

WriteOnceBlock<T>

Veri akışı blokları ağındaki en fazla bir öğeyi almak ve depolamak için bir arabellek sağlar.

Yapılar

DataflowMessageHeader

Veri akışı blokları arasında geçiş için bir veri öznitelikleri kapsayıcısı sağlar.

Arabirimler

IDataflowBlock

Veri akışı bloğunu temsil eder.

IPropagatorBlock<TInput,TOutput>

Hem veriler için hedef hem de veri kaynağı olan bir veri akışı bloğunu temsil eder.

IReceivableSourceBlock<TOutput>

Bağlama olmadan ileti almayı destekleyen bir veri akışı bloğunu temsil eder.

ISourceBlock<TOutput>

Veri kaynağı olan bir veri akışı bloğunu temsil eder.

ITargetBlock<TInput>

Veriler için hedef olan bir veri akışı bloğunu temsil eder.

Numaralandırmalar

DataflowMessageStatus

Veri akışı blokları arasında geçirildiğinde durumunu DataflowMessageHeader temsil eder.

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 .

Daha fazla bilgi için bkz. veri akışı.