ActionBlock<TInput> Konstruktory
Definice
Důležité
Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.
Přetížení
| ActionBlock<TInput>(Action<TInput>) |
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí. |
| ActionBlock<TInput>(Func<TInput,Task>) |
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí. |
| ActionBlock<TInput>(Action<TInput>, ExecutionDataflowBlockOptions) |
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanými akcemi a možnostmi konfigurace. |
| ActionBlock<TInput>(Func<TInput,Task>, ExecutionDataflowBlockOptions) |
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanými akcemi a možnostmi konfigurace. |
ActionBlock<TInput>(Action<TInput>)
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí.
public:
ActionBlock(Action<TInput> ^ action);public ActionBlock (Action<TInput> action);new System.Threading.Tasks.Dataflow.ActionBlock<'Input> : Action<'Input> -> System.Threading.Tasks.Dataflow.ActionBlock<'Input>Public Sub New (action As Action(Of TInput))Parametry
- action
- Action<TInput>
Akce, která se má vyvolat s každým přijatým datovým prvkem.
Výjimky
action je null.
Platí pro
ActionBlock<TInput>(Func<TInput,Task>)
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí.
public:
ActionBlock(Func<TInput, System::Threading::Tasks::Task ^> ^ action);public ActionBlock (Func<TInput,System.Threading.Tasks.Task> action);new System.Threading.Tasks.Dataflow.ActionBlock<'Input> : Func<'Input, System.Threading.Tasks.Task> -> System.Threading.Tasks.Dataflow.ActionBlock<'Input>Public Sub New (action As Func(Of TInput, Task))Parametry
Výjimky
action je null.
Platí pro
ActionBlock<TInput>(Action<TInput>, ExecutionDataflowBlockOptions)
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanými akcemi a možnostmi konfigurace.
public:
ActionBlock(Action<TInput> ^ action, System::Threading::Tasks::Dataflow::ExecutionDataflowBlockOptions ^ dataflowBlockOptions);public ActionBlock (Action<TInput> action, System.Threading.Tasks.Dataflow.ExecutionDataflowBlockOptions dataflowBlockOptions);new System.Threading.Tasks.Dataflow.ActionBlock<'Input> : Action<'Input> * System.Threading.Tasks.Dataflow.ExecutionDataflowBlockOptions -> System.Threading.Tasks.Dataflow.ActionBlock<'Input>Public Sub New (action As Action(Of TInput), dataflowBlockOptions As ExecutionDataflowBlockOptions)Parametry
- action
- Action<TInput>
Akce, která se má vyvolat s každým přijatým datovým prvkem.
- dataflowBlockOptions
- ExecutionDataflowBlockOptions
Možnosti, se kterými se má tato ActionBlock<TInput>konfigurace konfigurovat .
Výjimky
Příklady
Následující příklad ukazuje, jak pomocí konstruktoru ActionBlock<TInput>(Action<TInput>, ExecutionDataflowBlockOptions) vytvořit nový ActionBlock<TInput> objekt. Tento příklad kódu je součástí rozsáhlejšího příkladu uvedeného v tématu Postupy: Určení stupně paralelismu v tématu bloku toku dat .
// Performs several computations by using dataflow and returns the elapsed
// time required to perform the computations.
static TimeSpan TimeDataflowComputations(int maxDegreeOfParallelism,
int messageCount)
{
// Create an ActionBlock<int> that performs some work.
var workerBlock = new ActionBlock<int>(
// Simulate work by suspending the current thread.
millisecondsTimeout => Thread.Sleep(millisecondsTimeout),
// Specify a maximum degree of parallelism.
new ExecutionDataflowBlockOptions
{
MaxDegreeOfParallelism = maxDegreeOfParallelism
});
// Compute the time that it takes for several messages to
// flow through the dataflow block.
Stopwatch stopwatch = new Stopwatch();
stopwatch.Start();
for (int i = 0; i < messageCount; i++)
{
workerBlock.Post(1000);
}
workerBlock.Complete();
// Wait for all messages to propagate through the network.
workerBlock.Completion.Wait();
// Stop the timer and return the elapsed number of milliseconds.
stopwatch.Stop();
return stopwatch.Elapsed;
}
' Demonstrates how to specify the maximum degree of parallelism
' when using dataflow.
Friend Class Program
' Performs several computations by using dataflow and returns the elapsed
' time required to perform the computations.
Private Shared Function TimeDataflowComputations(ByVal maxDegreeOfParallelism As Integer, ByVal messageCount As Integer) As TimeSpan
' Create an ActionBlock<int> that performs some work.
Dim workerBlock = New ActionBlock(Of Integer)(Function(millisecondsTimeout) Pause(millisecondsTimeout), New ExecutionDataflowBlockOptions() With { .MaxDegreeOfParallelism = maxDegreeOfParallelism})
' Simulate work by suspending the current thread.
' Specify a maximum degree of parallelism.
' Compute the time that it takes for several messages to
' flow through the dataflow block.
Dim stopwatch As New Stopwatch()
stopwatch.Start()
For i As Integer = 0 To messageCount - 1
workerBlock.Post(1000)
Next i
workerBlock.Complete()
' Wait for all messages to propagate through the network.
workerBlock.Completion.Wait()
' Stop the timer and return the elapsed number of milliseconds.
stopwatch.Stop()
Return stopwatch.Elapsed
End Function
Private Shared Function Pause(ByVal obj As Object)
Thread.Sleep(obj)
Return Nothing
End Function
Platí pro
ActionBlock<TInput>(Func<TInput,Task>, ExecutionDataflowBlockOptions)
Inicializuje novou instanci ActionBlock<TInput> třídy se zadanými akcemi a možnostmi konfigurace.
public:
ActionBlock(Func<TInput, System::Threading::Tasks::Task ^> ^ action, System::Threading::Tasks::Dataflow::ExecutionDataflowBlockOptions ^ dataflowBlockOptions);public ActionBlock (Func<TInput,System.Threading.Tasks.Task> action, System.Threading.Tasks.Dataflow.ExecutionDataflowBlockOptions dataflowBlockOptions);new System.Threading.Tasks.Dataflow.ActionBlock<'Input> : Func<'Input, System.Threading.Tasks.Task> * System.Threading.Tasks.Dataflow.ExecutionDataflowBlockOptions -> System.Threading.Tasks.Dataflow.ActionBlock<'Input>Public Sub New (action As Func(Of TInput, Task), dataflowBlockOptions As ExecutionDataflowBlockOptions)Parametry
- dataflowBlockOptions
- ExecutionDataflowBlockOptions
Možnosti, se kterými se má tato ActionBlock<TInput>konfigurace konfigurovat .