Propriedade Scheduler.ThreadPool

Artigo
06/28/2011

Obtém o agendador que agenda o trabalho no ThreadPool.

Namespace:System.Reactive.Concurrency
Assembly: System.Reactive (em System.Reactive.dll)

Sintaxe

'Declaration
Public Shared ReadOnly Property ThreadPool As ThreadPoolScheduler
    Get

'Usage
Dim value As ThreadPoolScheduler

value = Scheduler.ThreadPool

public static ThreadPoolScheduler ThreadPool { get; }

public:
static property ThreadPoolScheduler^ ThreadPool {
    ThreadPoolScheduler^ get ();
}

static member ThreadPool : ThreadPoolScheduler

static function get ThreadPool () : ThreadPoolScheduler

Valor da propriedade

Tipo: System.Reactive.Concurrency.ThreadPoolScheduler
O agendador do pool de threads.

Comentários

O agendador threadPool agenda ações a serem executadas no pool de threads do .NET. Esse agendador é ideal para operações de execução curta.

Exemplos

Este exemplo de código usa o operador Generate para gerar uma sequência de inteiros que são quadrados perfeitos inferiores a 1000. O processamento associado ao operador generate está agendado para ser executado no pool de threads do .NET usando o agendador ThreadPool.

using System;
using System.Reactive.Linq;
using System.Reactive.Concurrency;

namespace Example
{
  class Program
  {
    static void Main()
    {
      //*********************************************************************************************//
      //*** Generate a sequence of integers which are the perfect squares that are less than 100  ***//
      //*********************************************************************************************//

      var obs = Observable.Generate(1,                      // Initial state value
                                    x => x * x < 1000,      // The termination condition. Terminate generation when false (the integer squared is not less than 1000)
                                    x => ++x,               // Iteration step function updates the state and returns the new state. In this case state is incremented by 1 
                                    x => x * x,             // Selector function determines the next resulting value in the sequence. The state of type in is squared.
                                    Scheduler.ThreadPool);  // The ThreadPool scheduler runs the generation on a thread pool thread instead of the main thread.

      using (IDisposable handle = obs.Subscribe(x => Console.WriteLine(x)))
      {
        Console.WriteLine("Press ENTER to exit...\n");
        Console.ReadLine();
      }
    }
  }
}

A saída a seguir demonstra a execução do código de exemplo.

Press ENTER to exit...

1
4
9
16
25
36
49
64
81
100
121
144
169
196
225
256
289
324
361
400
441
484
529
576
625
676
729
784
841
900
961

Consulte Também

Referência

Classe Scheduler

System.Reactive.Concurrency Namespace

Compartilhar via