System.Threading.Tasks.Dataflow Névtér

Egy aktoralapú programozási modellt biztosít, amely támogatja a folyamaton belüli üzenetátadást a durva szemcsés adatfolyamokhoz és a pipelining feladatokhoz.

Osztályok

Name Description
ActionBlock<TInput>

Egy adatfolyamblokkot biztosít, amely minden fogadott adatelemhez meghív egy megadott Action<T> meghatalmazottat.

BatchBlock<T>

Egy adatfolyamblokkot biztosít, amely tömbökbe köti a bemeneteket.

BatchedJoinBlock<T1,T2>

Olyan adatfolyamblokkot biztosít, amely meghatározott számú, potenciálisan eltérő típusú bemenetet kötegel egy vagy több célhoz.

BatchedJoinBlock<T1,T2,T3>

Olyan adatfolyamblokkot biztosít, amely meghatározott számú, potenciálisan eltérő típusú bemenetet kötegel egy vagy több célhoz.

BroadcastBlock<T>

Puffert biztosít egyszerre legfeljebb egy elem tárolásához, és felülírja az egyes üzeneteket a következővel, amint megérkezik.

BufferBlock<T>

Puffert biztosít az adatfolyamok adatainak tárolásához.

DataflowBlock

Statikus (megosztott Visual Basic) metódusokat biztosít az adatfolyamblokkok használatához.

DataflowBlockOptions

Az adatfolyamblokkok által végzett feldolgozás konfigurálására szolgáló beállításokat biztosít.

DataflowLinkOptions

Az adatfolyamblokkok közötti kapcsolat konfigurálásához használható beállításokat biztosít.

ExecutionDataflowBlockOptions

Az egyes üzeneteket felhasználó által megadott meghatalmazott meghívásával feldolgozó adatfolyamblokkok által végzett feldolgozás konfigurálására szolgáló beállításokat biztosít. Ezek adatfolyamblokkok, például ActionBlock<TInput> és TransformBlock<TInput,TOutput>.

GroupingDataflowBlockOptions

A több üzenetet csoportosító adatfolyamblokkok által végzett feldolgozás konfigurálására szolgáló beállításokat biztosít. Ezek adatfolyamblokkok, például JoinBlock<T1,T2> és BatchBlock<T>.

JoinBlock<T1,T2>

Olyan adatfolyamblokkot biztosít, amely több adatfolyamforráshoz csatlakozik, nem feltétlenül azonos típusúak, és arra vár, hogy minden típushoz egy elem érkezzen, mielőtt az összes elem egyszerre jelenik meg, típusonként egy elemből álló rekordként.

JoinBlock<T1,T2,T3>

Olyan adatfolyamblokkot biztosít, amely több adatfolyamforráshoz csatlakozik, amelyek nem feltétlenül azonos típusúak, és arra várnak, hogy minden egyes típushoz egy elem érkezzen, mielőtt az összes elem egyszerre jelenik meg, mint egy rekord, amely típusonként egy elemet tartalmaz.

TransformBlock<TInput,TOutput>

Egy adatfolyamblokkot biztosít, amely minden fogadott adatelemhez meghív egy megadott Func<T,TResult> meghatalmazottat.

TransformManyBlock<TInput,TOutput>

Egy adatfolyamblokkot biztosít, amely minden fogadott adatelemhez meghív egy megadott Func<T,TResult> meghatalmazottat.

WriteOnceBlock<T>

Puffert biztosít az adatfolyamblokkok hálózatának legfeljebb egy elemének fogadásához és tárolásához.

Struktúrák

Name Description
DataflowMessageHeader

Adatattribútumokat tartalmazó tárolót biztosít az adatfolyamblokkok közötti továbbításhoz.

Interfészek

Name Description
IDataflowBlock

Adatfolyamblokkot jelöl.

IPropagatorBlock<TInput,TOutput>

Olyan adatfolyamblokkot jelöl, amely az adatok és az adatforrások célhelye is.

IReceivableSourceBlock<TOutput>

Olyan adatfolyamblokkot jelöl, amely támogatja az üzenetek csatolás nélküli fogadását.

ISourceBlock<TOutput>

Olyan adatfolyamblokkot jelöl, amely adatforrás.

ITargetBlock<TInput>

Olyan adatfolyamblokkot jelöl, amely az adatok célhelye.

Enumerációk

Name Description
DataflowMessageStatus

DataflowMessageHeader Az adatfolyamblokkok között átadott állapotot jelöli.

Megjegyzések

Note

A TPL-adatfolyamtár (a System.Threading.Tasks.Dataflow névtér) nincs elosztva a .NET-tel. Ha telepíteni szeretné a System.Threading.Tasks.Dataflow névteret a Visual Studióban, nyissa meg a projektet, válassza NuGet-csomagok kezelése a Project menüjében, és keressen online a System.Threading.Tasks.Dataflow csomagra. Másik lehetőségként a .NET Core CLI használatával telepítheti, futtassa a dotnet add package System.Threading.Tasks.Dataflow.

További információ: Adatfolyam.