ActionBlock<TInput> Třída

Definice

Obor názvů:

System.Threading.Tasks.Dataflow

Sestavení:

System.Threading.Tasks.Dataflow.dll

Poskytuje blok toku dat, který vyvolá zadaného Action<T> delegáta 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

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

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

Parametry typu

TInput

Typ dat, na kterých 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í rozsáhlejšího příkladu uvedeného v článku o postupu: 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

Poznámka

Knihovna TPL Dataflow ( System.Threading.Tasks.Dataflow obor názvů) není distribuována s rozhraním .NET. Chcete-li System.Threading.Tasks.Dataflow v aplikaci Visual Studio nainstalovat obor názvů, otevřete projekt, v nabídce projekt vyberte možnost Spravovat balíčky NuGet a vyhledejte balíček online System.Threading.Tasks.Dataflow . Případně ho můžete nainstalovat pomocí .NET Core CLIspuštěním dotnet add package System.Threading.Tasks.Dataflow .

Konstruktory

ActionBlock<TInput>(Action<TInput>)	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>)	Inicializuje novou instanci ActionBlock<TInput> třídy se zadanou akcí.
ActionBlock<TInput>(Func<TInput,Task>, ExecutionDataflowBlockOptions)	Inicializuje novou instanci ActionBlock<TInput> třídy se zadanými akcemi a možnostmi konfigurace.

Vlastnosti

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

Complete()	Signály bloku toku dat, který 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.
Equals(Object)	Určí, zda se zadaný objekt rovná aktuálnímu objektu. (Zděděno od Object)
GetHashCode()	Slouží jako výchozí funkce hash. (Zděděno od Object)
GetType()	Type Získá aktuální instanci. (Zděděno od Object)
MemberwiseClone()	Vytvoří použádnou kopii aktuálního souboru Object. (Zděděno od Object)
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í

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í možnost zprávu využívat nebo odložit.

Metody rozšíření

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