ActionBlock<TInput> Sınıf

Tanım

Ad Alanı:

System.Threading.Tasks.Dataflow

Bütünleştirilmiş Kod:

System.Threading.Tasks.Dataflow.dll

Alınan her veri öğesi için sağlanan Action<T> bir temsilciyi çağıran bir veri akışı bloğu sağlar.

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)

Tür Parametreleri

TInput

Bunun ActionBlock<TInput> üzerinde çalıştığı veri türü.

Devralma

Object

ActionBlock<TInput>

Uygulamalar

IDataflowBlock ITargetBlock<TInput>

Örnekler

Aşağıdaki örnek, veri akışı bloklarını kullanarak birkaç hesaplama gerçekleştirmek için sınıfının kullanımını ActionBlock<TInput> gösterir ve hesaplamaları gerçekleştirmek için gereken geçen süreyi döndürür. Bu kod örneği, Nasıl yapılır: Veri Akışı Bloğunda Paralellik Derecesini Belirtme makalesinde sağlanan daha büyük bir örneğin bir parçasıdır.

// 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

Açıklamalar

Not

TPL veri akışı kitaplığı ( System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. System.Threading.Tasks.DataflowVisual Studio 'da ad alanını yüklemek için projenizi açın, Proje menüsünden NuGet Paketlerini Yönet ' i seçin ve paketi çevrimiçi olarak arayın System.Threading.Tasks.Dataflow . Alternatif olarak, .NET Core CLIkullanarak yüklemek için öğesini çalıştırın dotnet add package System.Threading.Tasks.Dataflow .

Oluşturucular

ActionBlock<TInput>(Action<TInput>)	Belirtilen eylemle sınıfının yeni bir örneğini ActionBlock<TInput> başlatır.
ActionBlock<TInput>(Action<TInput>, ExecutionDataflowBlockOptions)	Belirtilen eylem ve yapılandırma seçenekleriyle sınıfının yeni bir örneğini ActionBlock<TInput> başlatır.
ActionBlock<TInput>(Func<TInput,Task>)	Belirtilen eylemle sınıfının yeni bir örneğini ActionBlock<TInput> başlatır.
ActionBlock<TInput>(Func<TInput,Task>, ExecutionDataflowBlockOptions)	Belirtilen eylem ve yapılandırma seçenekleriyle sınıfının yeni bir örneğini ActionBlock<TInput> başlatır.

Özellikler

Completion	Zaman uyumsuz işlemi ve veri akışı bloğunun tamamlanmasını temsil eden bir Task nesnesi alır.
InputCount	Bu blok tarafından işlenmeyi bekleyen giriş öğelerinin sayısını alır.

Yöntemler

Complete()	Veri akışı bloğuna, daha fazla ileti kabul etmemesi veya üretmemesi ve daha fazla ertelenmiş ileti kullanmaması gerektiğini belirten sinyaller.
Equals(Object)	Belirtilen nesnenin geçerli nesneye eşit olup olmadığını belirler. (Devralındığı yer: Object)
GetHashCode()	Varsayılan karma işlevi işlevi görür. (Devralındığı yer: Object)
GetType()	Type Geçerli örneğini alır. (Devralındığı yer: Object)
MemberwiseClone()	Geçerli Objectöğesinin sığ bir kopyasını oluşturur. (Devralındığı yer: Object)
Post(TInput)	Bir öğeyi hedef veri akışı bloğuna postalar.
ToString()	Bu IDataflowBlock örneğin biçimlendirilmiş adını temsil eden bir dize döndürür.

Belirtik Arabirim Kullanımları

IDataflowBlock.Fault(Exception)	Veri akışı bloğunun hatalı durumda tamamlanmasını sağlar.
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	Veri akışı bloğuna bir ileti sunar ve iletiyi kullanma veya erteleme fırsatı verir.

Uzantı Metotları

AsObserver<TInput>(ITargetBlock<TInput>)	üzerinde ITargetBlock<TInput>yeni IObserver<T> bir soyutlama oluşturur.
Post<TInput>(ITargetBlock<TInput>, TInput)	Öğesine bir öğe postalar ITargetBlock<TInput>.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Zaman uyumsuz olarak hedef ileti bloğuna bir ileti seçerek ertelemeye olanak tanır.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Zaman uyumsuz olarak hedef ileti bloğuna bir ileti seçerek ertelemeye olanak tanır.