ConcurrentExclusiveSchedulerPair Třída

Definice

Obor názvů:

System.Threading.Tasks

Sestavení:

System.Threading.Tasks.dll

Sestavení:

System.Runtime.dll

Sestavení:

mscorlib.dll

Sestavení:

netstandard.dll

Poskytuje plánovače úloh, které koordinují provádění úkolů a zároveň zajišťují, aby souběžné úlohy mohly běžet souběžně a exkluzivní úlohy nikdy nedělaly.

public ref class ConcurrentExclusiveSchedulerPair

public class ConcurrentExclusiveSchedulerPair

type ConcurrentExclusiveSchedulerPair = class

Public Class ConcurrentExclusiveSchedulerPair

Dědičnost

Object

ConcurrentExclusiveSchedulerPair

Příklady

Následující příklad ukazuje použití ConcurrentExclusiveSchedulerPair třídy. Čtenáři běží na souběžné části plánovače. Zapisovač běží ve výhradní části plánovače. Tento příklad kódu je součástí rozsáhlejšího příkladu uvedeného v článku Postupy: Určení plánovače úloh v článku Blok toku dat .

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

Konstruktory

ConcurrentExclusiveSchedulerPair()	Inicializuje novou instanci ConcurrentExclusiveSchedulerPair třídy.
ConcurrentExclusiveSchedulerPair(TaskScheduler)	Inicializuje novou instanci ConcurrentExclusiveSchedulerPair třídy, která cílí na zadaný plánovač.
ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32)	Inicializuje novou instanci ConcurrentExclusiveSchedulerPair třídy, která cílí na zadaný plánovač s maximální úrovní souběžnosti.
ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32, Int32)	Inicializuje novou instanci ConcurrentExclusiveSchedulerPair třídy, která cílí na zadaný plánovač s maximální úrovní souběžnosti a maximální počet naplánovaných úkolů, které mohou být zpracovány jako jednotka.

Vlastnosti

Completion	Task Získá, který se dokončí po dokončení zpracování plánovače.
ConcurrentScheduler	TaskScheduler Získá, který lze použít k naplánování úkolů pro tento pár, který může běžet souběžně s dalšími úlohami v tomto páru.
ExclusiveScheduler	TaskScheduler Získá, který lze použít k naplánování úkolů pro tento pár, který musí běžet výhradně s ohledem na jiné úkoly v tomto páru.

Metody

Complete()	Informuje dvojici plánovače, že by neměla přijímat žádné další úkoly.
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)
ToString()	Vrátí řetězec, který představuje aktuální objekt. (Zděděno od Object)