System.Threading.Tasks.Dataflow Naamruimte

Biedt een programmeermodel op basis van een actor dat ondersteuning biedt voor in-process message passing voor grofkorrelige gegevensstromen en pipelining-taken.

Klassen

Name Description
ActionBlock<TInput>

Biedt een gegevensstroomblok dat een opgegeven Action<T> gemachtigde aanroept voor elk ontvangen gegevenselement.

BatchBlock<T>

Biedt een gegevensstroomblok dat invoer in matrices batcheert.

BatchedJoinBlock<T1,T2>

Biedt een gegevensstroomblok dat een opgegeven aantal invoergegevens batcheert van mogelijk verschillende typen die aan een of meer van de doelen zijn geleverd.

BatchedJoinBlock<T1,T2,T3>

Biedt een gegevensstroomblok dat een opgegeven aantal invoergegevens batcheert van mogelijk verschillende typen die aan een of meer van de doelen zijn geleverd.

BroadcastBlock<T>

Biedt een buffer voor het opslaan van maximaal één element tegelijk, waarbij elk bericht wordt overschreven met het volgende wanneer het binnenkomt.

BufferBlock<T>

Biedt een buffer voor het opslaan van gegevens voor een gegevensstroom.

DataflowBlock

Biedt een set statische methoden (gedeeld in Visual Basic) voor het werken met gegevensstroomblokken.

DataflowBlockOptions

Biedt opties die worden gebruikt voor het configureren van de verwerking die wordt uitgevoerd door gegevensstroomblokken.

DataflowLinkOptions

Biedt opties voor het configureren van een koppeling tussen gegevensstroomblokken.

ExecutionDataflowBlockOptions

Biedt opties voor het configureren van de verwerking die wordt uitgevoerd door gegevensstroomblokken die elk bericht verwerken via de aanroep van een door de gebruiker opgegeven gemachtigde. Dit zijn gegevensstroomblokken zoals ActionBlock<TInput> en TransformBlock<TInput,TOutput>.

GroupingDataflowBlockOptions

Biedt opties voor het configureren van de verwerking die wordt uitgevoerd door gegevensstroomblokken die meerdere berichten groeperen. Dit zijn gegevensstroomblokken zoals JoinBlock<T1,T2> en BatchBlock<T>.

JoinBlock<T1,T2>

Biedt een gegevensstroomblok dat wordt samengevoegd in meerdere gegevensstroombronnen, niet noodzakelijkerwijs van hetzelfde type, waarbij wordt gewacht tot één item voor elk type binnenkomt voordat ze allemaal samen worden vrijgegeven als een tuple die uit één item per type bestaat.

JoinBlock<T1,T2,T3>

Biedt een gegevensstroomblok dat wordt samengevoegd in meerdere gegevensstroombronnen, die niet noodzakelijkerwijs van hetzelfde type zijn, en wacht tot één item voor elk type binnenkomt voordat ze allemaal worden vrijgegeven als een tuple die één item per type bevat.

TransformBlock<TInput,TOutput>

Biedt een gegevensstroomblok dat een opgegeven Func<T,TResult> gemachtigde aanroept voor elk ontvangen gegevenselement.

TransformManyBlock<TInput,TOutput>

Biedt een gegevensstroomblok dat een opgegeven Func<T,TResult> gemachtigde aanroept voor elk ontvangen gegevenselement.

WriteOnceBlock<T>

Biedt een buffer voor het ontvangen en opslaan van maximaal één element in een netwerk van gegevensstroomblokken.

Structs

Name Description
DataflowMessageHeader

Biedt een container met gegevenskenmerken voor het doorgeven tussen gegevensstroomblokken.

Interfaces

Name Description
IDataflowBlock

Vertegenwoordigt een gegevensstroomblok.

IPropagatorBlock<TInput,TOutput>

Vertegenwoordigt een gegevensstroomblok dat zowel een doel is voor gegevens als een gegevensbron.

IReceivableSourceBlock<TOutput>

Vertegenwoordigt een gegevensstroomblok dat ondersteuning biedt voor het ontvangen van berichten zonder koppeling.

ISourceBlock<TOutput>

Vertegenwoordigt een gegevensstroomblok dat een gegevensbron is.

ITargetBlock<TInput>

Vertegenwoordigt een gegevensstroomblok dat een doel is voor gegevens.

Enums

Name Description
DataflowMessageStatus

Vertegenwoordigt de status van een DataflowMessageHeader wanneer deze wordt doorgegeven tussen gegevensstroomblokken.

Opmerkingen

Note

De TPL-gegevensstroombibliotheek (de System.Threading.Tasks.Dataflow naamruimte) wordt niet gedistribueerd met .NET. Als u de System.Threading.Tasks.Dataflow-naamruimte in Visual Studio wilt installeren, opent u uw project, kiest u NuGet-pakketten beheren in het menu Project en zoekt u online naar het System.Threading.Tasks.Dataflow-pakket. Om deze te installeren met behulp van de .NET Core CLI, voert u dotnet add package System.Threading.Tasks.Dataflowuit.

Zie Gegevensstroom voor meer informatie.