ConcurrentExclusiveSchedulerPair Classe

Definição

Namespace:

System.Threading.Tasks

Assembly:

System.Threading.Tasks.dll

Assembly:

System.Runtime.dll

Assembly:

mscorlib.dll

Assembly:

netstandard.dll

Fornece agendadores de tarefa que se coordenam para executar tarefas, enquanto garantem que as tarefas simultâneas possam ser executadas simultaneamente e as tarefas exclusivas nunca.

public ref class ConcurrentExclusiveSchedulerPair

public class ConcurrentExclusiveSchedulerPair

type ConcurrentExclusiveSchedulerPair = class

Public Class ConcurrentExclusiveSchedulerPair

Herança

Object

ConcurrentExclusiveSchedulerPair

Exemplos

O exemplo a seguir mostra o uso da ConcurrentExclusiveSchedulerPair classe. Os leitores são executados na parte simultânea do agendador. O gravador é executado na parte exclusiva do agendador. Este exemplo de código faz parte de um exemplo maior fornecido para o artigo Como especificar um agendador de tarefas em um artigo do Bloco de Fluxo de Dados .

// Create a ConcurrentExclusiveSchedulerPair object.
// Readers will run on the concurrent part of the scheduler pair.
// The writer will run on the exclusive part of the scheduler pair.
var taskSchedulerPair = new ConcurrentExclusiveSchedulerPair();

// Create an ActionBlock<int> object for each reader CheckBox object.
// Each ActionBlock<int> object represents an action that can read 
// from a resource in parallel to other readers.
// Specifying the concurrent part of the scheduler pair enables the 
// reader to run in parallel to other actions that are managed by 
// that scheduler.
var readerActions =
   from checkBox in new CheckBox[] { checkBox1, checkBox2, checkBox3 }
   select new ActionBlock<int>(milliseconds =>
   {
       // Toggle the check box to the checked state.
       toggleCheckBox.Post(checkBox);

       // Perform the read action. For demonstration, suspend the current
       // thread to simulate a lengthy read operation.
       Thread.Sleep(milliseconds);

       // Toggle the check box to the unchecked state.
       toggleCheckBox.Post(checkBox);
   },
   new ExecutionDataflowBlockOptions
   {
       TaskScheduler = taskSchedulerPair.ConcurrentScheduler
   });

// Create an ActionBlock<int> object for the writer CheckBox object.
// This ActionBlock<int> object represents an action that writes to 
// a resource, but cannot run in parallel to readers.
// Specifying the exclusive part of the scheduler pair enables the 
// writer to run in exclusively with respect to other actions that are 
// managed by the scheduler pair.
var writerAction = new ActionBlock<int>(milliseconds =>
{
    // Toggle the check box to the checked state.
    toggleCheckBox.Post(checkBox4);

    // Perform the write action. For demonstration, suspend the current
    // thread to simulate a lengthy write operation.
    Thread.Sleep(milliseconds);

    // Toggle the check box to the unchecked state.
    toggleCheckBox.Post(checkBox4);
},
new ExecutionDataflowBlockOptions
{
    TaskScheduler = taskSchedulerPair.ExclusiveScheduler
});

// Link the broadcaster to each reader and writer block.
// The BroadcastBlock<T> class propagates values that it 
// receives to all connected targets.
foreach (var readerAction in readerActions)
{
    broadcaster.LinkTo(readerAction);
}
broadcaster.LinkTo(writerAction);

' Create a ConcurrentExclusiveSchedulerPair object.
' Readers will run on the concurrent part of the scheduler pair.
' The writer will run on the exclusive part of the scheduler pair.
Dim taskSchedulerPair = New ConcurrentExclusiveSchedulerPair()

' Create an ActionBlock<int> object for each reader CheckBox object.
' Each ActionBlock<int> object represents an action that can read 
' from a resource in parallel to other readers.
' Specifying the concurrent part of the scheduler pair enables the 
' reader to run in parallel to other actions that are managed by 
' that scheduler.
Dim readerActions = From checkBox In New CheckBox() {checkBox1, checkBox2, checkBox3}
                    Select New ActionBlock(Of Integer)(Sub(milliseconds)
                                                           ' Toggle the check box to the checked state.
                                                           ' Perform the read action. For demonstration, suspend the current
                                                           ' thread to simulate a lengthy read operation.
                                                           ' Toggle the check box to the unchecked state.
                                                           toggleCheckBox.Post(checkBox)
                                                           Thread.Sleep(milliseconds)
                                                           toggleCheckBox.Post(checkBox)
                                                       End Sub, New ExecutionDataflowBlockOptions With {.TaskScheduler = taskSchedulerPair.ConcurrentScheduler})

' Create an ActionBlock<int> object for the writer CheckBox object.
' This ActionBlock<int> object represents an action that writes to 
' a resource, but cannot run in parallel to readers.
' Specifying the exclusive part of the scheduler pair enables the 
' writer to run in exclusively with respect to other actions that are 
' managed by the scheduler pair.
Dim writerAction = New ActionBlock(Of Integer)(Sub(milliseconds)
                                                   ' Toggle the check box to the checked state.
                                                   ' Perform the write action. For demonstration, suspend the current
                                                   ' thread to simulate a lengthy write operation.
                                                   ' Toggle the check box to the unchecked state.
                                                   toggleCheckBox.Post(checkBox4)
                                                   Thread.Sleep(milliseconds)
                                                   toggleCheckBox.Post(checkBox4)
                                               End Sub, New ExecutionDataflowBlockOptions With {.TaskScheduler = taskSchedulerPair.ExclusiveScheduler})

' Link the broadcaster to each reader and writer block.
' The BroadcastBlock<T> class propagates values that it 
' receives to all connected targets.
For Each readerAction In readerActions
    broadcaster.LinkTo(readerAction)
Next readerAction
broadcaster.LinkTo(writerAction)

Construtores

ConcurrentExclusiveSchedulerPair()	Inicializa uma nova instância da classe ConcurrentExclusiveSchedulerPair.
ConcurrentExclusiveSchedulerPair(TaskScheduler)	Inicializa uma nova instância da classe ConcurrentExclusiveSchedulerPair que tem visa o agendador especificado.
ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32)	Inicializa uma nova instância da classe ConcurrentExclusiveSchedulerPair que tem visa o agendador especificado com um nível de simultaneidade máximo.
ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32, Int32)	Inicializa uma nova instância da classe ConcurrentExclusiveSchedulerPair que visa o agendador especificado com um nível de simultaneidade máximo e um número máximo de tarefas agendadas que podem ser processadas como uma unidade.

Propriedades

Completion	Obtém um Task que será concluído quando o agendador concluir o processamento.
ConcurrentScheduler	Obtém um TaskScheduler que pode ser usado para agendar tarefas para esse par que devem ser executadas simultaneamente com outras tarefas nesse par.
ExclusiveScheduler	Obtém um TaskScheduler que pode ser usado para agendar tarefas para esse par que devem ser executadas exclusivamente com relação a outras tarefas nesse par.

Métodos

Complete()	Informa o par de agendador que ele não deve aceitar mais nenhuma tarefa.
Equals(Object)	Determina se o objeto especificado é igual ao objeto atual. (Herdado de Object)
GetHashCode()	Serve como a função de hash padrão. (Herdado de Object)
GetType()	Obtém o Type da instância atual. (Herdado de Object)
MemberwiseClone()	Cria uma cópia superficial do Object atual. (Herdado de Object)
ToString()	Retorna uma cadeia de caracteres que representa o objeto atual. (Herdado de Object)