ActionBlock<TInput>.Complete Metode

Definisi

Ruang nama:

System.Threading.Tasks.Dataflow

Rakitan:

System.Threading.Tasks.Dataflow.dll

Sumber:

ActionBlock.cs

Sinyal ke blok aliran data yang seharusnya tidak menerima atau menghasilkan pesan lagi dan tidak boleh menggunakan pesan yang ditunda lagi.

public:
 virtual void Complete();

public void Complete();

abstract member Complete : unit -> unit
override this.Complete : unit -> unit

Public Sub Complete ()

Penerapan

Complete()

Contoh

Contoh berikut menunjukkan penggunaan Complete metode untuk memberi sinyal ke blok aliran data yang seharusnya tidak diterima atau menghasilkan pesan lagi atau tidak menggunakan pesan yang ditunda lagi. Contoh kode ini adalah bagian dari contoh yang lebih besar yang disediakan untuk Cara: Menentukan Tingkat Paralelisme dalam topik Blok Aliran Data .

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

Keterangan

Setelah Complete dipanggil pada blok aliran data, blok tersebut akan selesai (sehingga tugasnya Completion akan memasuki status akhir) setelah memproses semua data yang tersedia sebelumnya. Metode ini tidak akan memblokir menunggu penyelesaian terjadi, tetapi akan memulai permintaan. Untuk menunggu penyelesaian terjadi, gunakan Completion properti .