ActionBlock<TInput> Třída

Definice

Obor názvů:

System.Threading.Tasks.Dataflow

Sestavení:

System.Threading.Tasks.Dataflow.dll

Balíček:

System.Threading.Tasks.Dataflow v11.0.0-preview.5.26302.115

Zdroj:

ActionBlock.cs

Poskytuje blok toku dat, který vyvolá zadaný Action<T> delegát pro každý přijatý datový prvek.

generic <typename TInput>
public ref class ActionBlock sealed : System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public sealed class ActionBlock<TInput> : System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

type ActionBlock<'Input> = class
    interface ITargetBlock<'Input>
    interface IDataflowBlock

Public NotInheritable Class ActionBlock(Of TInput)
Implements ITargetBlock(Of TInput)

Parametry typu

TInput

Typ dat, se kterými se pracuje ActionBlock<TInput> .

Dědičnost

Object

ActionBlock<TInput>

Implementuje

IDataflowBlock ITargetBlock<TInput>

Příklady

Následující příklad ukazuje použití ActionBlock<TInput> třídy k provedení několika výpočtů pomocí bloků toku dat a vrátí uplynulý čas potřebný k provedení výpočtů. Tento příklad kódu je součástí většího příkladu, který je uveden v článku Postupy: Určení stupně paralelismu v 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

Poznámky

Note

Knihovna toku dat TPL (jmenný prostor System.Threading.Tasks.Dataflow) není distribuována s .NET. Pokud chcete nainstalovat obor názvů System.Threading.Tasks.Dataflow v sadě Visual Studio, otevřete projekt, zvolte v nabídce Projekt možnost Spravovat balíčky NuGet a balíček System.Threading.Tasks.Dataflow vyhledejte online. Případně ji můžete nainstalovat pomocí rozhraní příkazového řádku .NET Core, spusťte dotnet add package System.Threading.Tasks.Dataflow.

Konstruktory

Name	Description
ActionBlock<TInput>(Action<TInput>, ExecutionDataflowBlockOptions)	Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí a možnostmi konfigurace.
ActionBlock<TInput>(Action<TInput>)	Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí.
ActionBlock<TInput>(Func<TInput,Task>, ExecutionDataflowBlockOptions)	Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí a možnostmi konfigurace.
ActionBlock<TInput>(Func<TInput,Task>)	Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí.

Vlastnosti

Name	Description
Completion	Task Získá objekt, který představuje asynchronní operaci a dokončení bloku toku dat.
InputCount	Získá počet vstupních položek čekajících na zpracování tímto blokem.

Metody

Name	Description
Complete()	Signalizuje blok toku dat, že by neměl přijímat ani vytvářet žádné další zprávy a neměl by spotřebovávat žádné odložené zprávy.
Post(TInput)	Publikuje položku do bloku cílového toku dat.
ToString()	Vrátí řetězec, který představuje formátovaný název této IDataflowBlock instance.

Explicitní implementace rozhraní

Name	Description
IDataflowBlock.Fault(Exception)	Způsobí, že se blok toku dat dokončí v chybném stavu.
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	Nabízí zprávu bloku toku dat a dává jí příležitost zprávu využívat nebo odložit.

Metody rozšíření

Name	Description
AsObserver<TInput>(ITargetBlock<TInput>)	Vytvoří novou IObserver<T> abstrakci přes ITargetBlock<TInput>.
Post<TInput>(ITargetBlock<TInput>, TInput)	Publikuje položku do souboru ITargetBlock<TInput>.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Asynchronně nabízí zprávu cílovému bloku zprávy, což umožňuje odložení.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Asynchronně nabízí zprávu cílovému bloku zprávy, což umožňuje odložení.