分享方式：

如何：管理排程器執行個體

  • 文章

排程器實例可讓您將特定排程原則與各種工作負載產生關聯。 本主題包含兩個基本範例，示範如何建立和管理排程器實例。

這些範例會建立使用預設排程器原則的排程器。 如需建立使用自訂原則的排程器範例，請參閱 如何：指定特定排程器原則 。

在應用程式中管理排程器實例

  1. 建立並行 ：：SchedulerPolicy 物件，其中包含要使用的排程器的原則值。

  2. 呼叫 concurrency：：CurrentScheduler：：Create 方法或 concurrency：：Scheduler：：Create 方法來建立排程器實例。

    如果您使用 Scheduler::Create 方法，當您需要將排程器與目前內容產生關聯時，請呼叫 concurrency：：Scheduler：：Attach 方法。

  3. 呼叫 CreateEvent 函式，以建立非訊號自動重設事件物件的控制碼。

  4. 將控制碼傳遞至您剛才建立的事件物件至 concurrency：：CurrentScheduler：：RegisterShutdownEvent 方法或 concurrency：：Scheduler：：RegisterShutdownEvent 方法。 這會註冊排程器終結時要設定的事件。

  5. 執行您希望目前排程器排程的工作。

  6. 呼叫 concurrency：：CurrentScheduler：:D etach 方法來卸離目前的排程器，並將先前的排程器還原為目前排程器。

    如果您使用 Scheduler::Create 方法，請呼叫 concurrency：：Scheduler：：Release 方法來遞減物件的參考計數 Scheduler 。

  7. 將控制碼傳遞至 WaitForSingleObject 函式，以等候排程器關閉。

  8. 呼叫 CloseHandle 函式以關閉事件物件的控制碼。

範例

下列程式碼示範兩種方式來管理排程器實例。 每個範例會先使用預設排程器來執行一項工作，以列印出目前排程器的唯一識別碼。 然後，每個範例都會使用排程器實例再次執行相同的工作。 最後，每個範例都會將預設排程器還原為目前的排程器，並再執行一次工作。

第一個範例會使用 並行：：CurrentScheduler 類別來建立排程器實例，並將它與目前內容產生關聯。 第二個範例會 使用並行：：Scheduler 類別來執行相同的工作。 一般而言，類別 CurrentScheduler 是用來處理目前的排程器。 第二個使用 類別的 Scheduler 範例，當您想要控制排程器何時與目前內容相關聯，或您想要將特定排程器與特定工作產生關聯時，會很有用。

// scheduler-instance.cpp
// compile with: /EHsc
#include <windows.h>
#include <ppl.h>
#include <iostream>

using namespace concurrency;
using namespace std;

// Prints the identifier of the current scheduler to the console.
void perform_task()
{
   // A task group.
   task_group tasks;

   // Run a task in the group. The current scheduler schedules the task.
   tasks.run_and_wait([] { 
      wcout << L"Current scheduler id: " << CurrentScheduler::Id() << endl;
   });
}

// Uses the CurrentScheduler class to manage a scheduler instance.
void current_scheduler()
{
   // Run the task.
   // This prints the identifier of the default scheduler.
   perform_task();

   // For demonstration, create a scheduler object that uses 
   // the default policy values.
   wcout << L"Creating and attaching scheduler..." << endl;
   CurrentScheduler::Create(SchedulerPolicy());

   // Register to be notified when the scheduler shuts down.
   HANDLE hShutdownEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
   CurrentScheduler::RegisterShutdownEvent(hShutdownEvent);

   // Run the task again.
   // This prints the identifier of the new scheduler.
   perform_task();

   // Detach the current scheduler. This restores the previous scheduler
   // as the current one.
   wcout << L"Detaching scheduler..." << endl;
   CurrentScheduler::Detach();

   // Wait for the scheduler to shut down and destroy itself.
   WaitForSingleObject(hShutdownEvent, INFINITE);

   // Close the event handle.
   CloseHandle(hShutdownEvent);

   // Run the sample task again.
   // This prints the identifier of the default scheduler.
   perform_task();
}

// Uses the Scheduler class to manage a scheduler instance.
void explicit_scheduler()
{
   // Run the task.
   // This prints the identifier of the default scheduler.
   perform_task();

   // For demonstration, create a scheduler object that uses 
   // the default policy values.
   wcout << L"Creating scheduler..." << endl;
   Scheduler* scheduler = Scheduler::Create(SchedulerPolicy());

   // Register to be notified when the scheduler shuts down.
   HANDLE hShutdownEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
   scheduler->RegisterShutdownEvent(hShutdownEvent);

   // Associate the scheduler with the current thread.
   wcout << L"Attaching scheduler..." << endl;
   scheduler->Attach();

   // Run the sample task again.
   // This prints the identifier of the new scheduler.
   perform_task();

   // Detach the current scheduler. This restores the previous scheduler
   // as the current one.
   wcout << L"Detaching scheduler..." << endl;
   CurrentScheduler::Detach();

   // Release the final reference to the scheduler. This causes the scheduler
   // to shut down after all tasks finish.
   scheduler->Release();

   // Wait for the scheduler to shut down and destroy itself.
   WaitForSingleObject(hShutdownEvent, INFINITE);

   // Close the event handle.
   CloseHandle(hShutdownEvent);

   // Run the sample task again.
   // This prints the identifier of the default scheduler.
   perform_task();
}

int wmain()
{
   // Use the CurrentScheduler class to manage a scheduler instance.
   wcout << L"Using CurrentScheduler class..." << endl << endl;
   current_scheduler();

   wcout << endl << endl;

   // Use the Scheduler class to manage a scheduler instance.
   wcout << L"Using Scheduler class..." << endl << endl;
   explicit_scheduler();
}

此範例會產生下列輸出。

Using CurrentScheduler class...

Current scheduler id: 0
Creating and attaching scheduler...
Current scheduler id: 1
Detaching scheduler...
Current scheduler id: 0

Using Scheduler class...

Current scheduler id: 0
Creating scheduler...
Attaching scheduler...
Current scheduler id: 2
Detaching scheduler...
Current scheduler id: 0

編譯程式碼

複製範例程式碼，並將其貼到 Visual Studio 專案中，或貼到名為 scheduler-instance.cpp 的檔案中，然後在 Visual Studio 命令提示字元視窗中執行下列命令。

cl.exe /EHsc scheduler-instance.cpp

另請參閱

排程器執行個體
如何：指定特定排程器原則