ConcurrentExclusiveSchedulerPair Konstruktoren
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair-Klasse.
Überlädt
| Name | Beschreibung |
|---|---|
| ConcurrentExclusiveSchedulerPair() |
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair-Klasse. |
| ConcurrentExclusiveSchedulerPair(TaskScheduler) |
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair Klasse, die auf den angegebenen Zeitplan ausgerichtet ist. |
| ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32) |
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair Klasse, die auf den angegebenen Zeitplan mit einer maximalen Parallelitätsebene ausgerichtet ist. |
| ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32, Int32) |
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair Klasse, die auf den angegebenen Zeitplan ausgerichtet ist, mit einer maximalen Parallelitätsstufe und einer maximalen Anzahl von geplanten Vorgängen, die als Einheit verarbeitet werden können. |
ConcurrentExclusiveSchedulerPair()
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair-Klasse.
public:
ConcurrentExclusiveSchedulerPair();public ConcurrentExclusiveSchedulerPair();Public Sub New ()Beispiele
Das folgende Beispiel zeigt die Verwendung des ConcurrentExclusiveSchedulerPair Konstruktors zum Erstellen eines neuen ConcurrentExclusiveSchedulerPair Objekts. Dieses Codebeispiel ist Teil eines größeren Beispiels, das für das Thema "How to: Specify a Task Scheduler" in einem Dataflow Block-Artikel bereitgestellt wird.
// 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)
Gilt für:
ConcurrentExclusiveSchedulerPair(TaskScheduler)
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair Klasse, die auf den angegebenen Zeitplan ausgerichtet ist.
public:
ConcurrentExclusiveSchedulerPair(System::Threading::Tasks::TaskScheduler ^ taskScheduler);public ConcurrentExclusiveSchedulerPair(System.Threading.Tasks.TaskScheduler taskScheduler);new System.Threading.Tasks.ConcurrentExclusiveSchedulerPair : System.Threading.Tasks.TaskScheduler -> System.Threading.Tasks.ConcurrentExclusiveSchedulerPairPublic Sub New (taskScheduler As TaskScheduler)Parameter
- taskScheduler
- TaskScheduler
Der Zielplaner, für den dieses Paar ausgeführt werden soll.
Gilt für:
ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32)
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair Klasse, die auf den angegebenen Zeitplan mit einer maximalen Parallelitätsebene ausgerichtet ist.
public:
ConcurrentExclusiveSchedulerPair(System::Threading::Tasks::TaskScheduler ^ taskScheduler, int maxConcurrencyLevel);public ConcurrentExclusiveSchedulerPair(System.Threading.Tasks.TaskScheduler taskScheduler, int maxConcurrencyLevel);new System.Threading.Tasks.ConcurrentExclusiveSchedulerPair : System.Threading.Tasks.TaskScheduler * int -> System.Threading.Tasks.ConcurrentExclusiveSchedulerPairPublic Sub New (taskScheduler As TaskScheduler, maxConcurrencyLevel As Integer)Parameter
- taskScheduler
- TaskScheduler
Der Zielplaner, für den dieses Paar ausgeführt werden soll.
- maxConcurrencyLevel
- Int32
Die maximale Anzahl von Aufgaben, die gleichzeitig ausgeführt werden sollen.
Gilt für:
ConcurrentExclusiveSchedulerPair(TaskScheduler, Int32, Int32)
Initialisiert eine neue Instanz der ConcurrentExclusiveSchedulerPair Klasse, die auf den angegebenen Zeitplan ausgerichtet ist, mit einer maximalen Parallelitätsstufe und einer maximalen Anzahl von geplanten Vorgängen, die als Einheit verarbeitet werden können.
public:
ConcurrentExclusiveSchedulerPair(System::Threading::Tasks::TaskScheduler ^ taskScheduler, int maxConcurrencyLevel, int maxItemsPerTask);public ConcurrentExclusiveSchedulerPair(System.Threading.Tasks.TaskScheduler taskScheduler, int maxConcurrencyLevel, int maxItemsPerTask);new System.Threading.Tasks.ConcurrentExclusiveSchedulerPair : System.Threading.Tasks.TaskScheduler * int * int -> System.Threading.Tasks.ConcurrentExclusiveSchedulerPairPublic Sub New (taskScheduler As TaskScheduler, maxConcurrencyLevel As Integer, maxItemsPerTask As Integer)Parameter
- taskScheduler
- TaskScheduler
Der Zielplaner, für den dieses Paar ausgeführt werden soll.
- maxConcurrencyLevel
- Int32
Die maximale Anzahl von Aufgaben, die gleichzeitig ausgeführt werden sollen.
- maxItemsPerTask
- Int32
Die maximale Anzahl von Vorgängen, die für jeden zugrunde liegenden geplanten Vorgang verarbeitet werden sollen, der vom Paar verwendet wird.
