Пошаговое руководство. Адаптация существующего кода для использования упрощенных задач

В этом разделе показано, как адаптировать существующий код, использующий интерфейс Windows API, для создания и выполнения потока, в котором используется упрощенная задача.

Упрощенная задача — это задача, планируемая непосредственно в объекте Concurrency::Scheduler или Concurrency::ScheduleGroup. Упрощенные задачи удобно использовать при адаптации существующего кода для использования функции планирования в среде выполнения с параллелизмом.

Обязательные компоненты

Прежде чем начать выполнение этого пошагового руководства, необходимо ознакомиться с разделом Планировщик задач (среда выполнения с параллелизмом).

Пример

Описание

В следующем примере демонстрируется типичное использование интерфейса Windows API для создания и выполнения потока. В этом примере для вызова MyThreadFunction в отдельном потоке используется функция CreateThread.

Код

// windows-threads.cpp
#include <windows.h>
#include <tchar.h>
#include <strsafe.h>

#define BUF_SIZE 255

DWORD WINAPI MyThreadFunction(LPVOID param);

// Data structure for threads to use.
typedef struct MyData {
    int val1;
    int val2;
} MYDATA, *PMYDATA;

int _tmain()
{
   // Allocate memory for thread data.
   PMYDATA pData = (PMYDATA) HeapAlloc(GetProcessHeap(), 
      HEAP_ZERO_MEMORY, sizeof(MYDATA));

   if( pData == NULL )
   {
      ExitProcess(2);
   }

   // Set the values of the thread data.
   pData->val1 = 50;
   pData->val2 = 100;

   // Create the thread to begin execution on its own.
   DWORD dwThreadId;
   HANDLE hThread = CreateThread( 
      NULL,                   // default security attributes
      0,                      // use default stack size  
      MyThreadFunction,       // thread function name
      pData,                  // argument to thread function 
      0,                      // use default creation flags 
      &dwThreadId);           // returns the thread identifier 

   if (hThread == NULL) 
   {      
      ExitProcess(3);
   }

   // Wait for the thread to finish.
   WaitForSingleObject(hThread, INFINITE);

   // Close the thread handle and free memory allocation.
   CloseHandle(hThread);
   HeapFree(GetProcessHeap(), 0, pData);

   return 0;
}

DWORD WINAPI MyThreadFunction(LPVOID lpParam)
{
   PMYDATA pData = (PMYDATA)lpParam;

   // Use thread-safe functions to print the parameter values.

   TCHAR msgBuf[BUF_SIZE];
   StringCchPrintf(msgBuf, BUF_SIZE, TEXT("Parameters = %d, %d\n"), 
     pData->val1, pData->val2); 

   size_t cchStringSize;
   StringCchLength(msgBuf, BUF_SIZE, &cchStringSize);

   DWORD dwChars;
   WriteConsole(GetStdHandle(STD_OUTPUT_HANDLE), msgBuf, (DWORD)cchStringSize, &dwChars, NULL);

   return 0;
}

Комментарии

После выполнения примера получается следующий результат.

Parameters = 50, 100

Ниже описана процедура адаптации примера кода для выполнения той же задачи с использованием среды выполнения с параллелизмом.

Адаптация примера для использования упрощенной задачи

1. Добавьте директиву #include для файла заголовка concrt.h.

   #include <concrt.h>
   

2. Добавьте директиву using для пространства имен Concurrency.

   using namespace Concurrency;
   

3. Измените объявление MyThreadFunction для использования соглашения о вызове __cdecl и возвращения значения void.

   void __cdecl MyThreadFunction(LPVOID param);
   

4. Измените структуру MyData, включив в нее объект Concurrency::event, сообщающий главному приложению, что задача завершена.

   typedef struct MyData {
       int val1;
       int val2;
       event signal;
   } MYDATA, *PMYDATA;
   

5. Замените вызов метода CreateThread вызовом метода Concurrency::CurrentScheduler::ScheduleTask.

   CurrentScheduler::ScheduleTask(MyThreadFunction, pData);
   

6. Чтобы дождаться завершения задачи, замените вызов метода WaitForSingleObject вызовом метода Concurrency::event::wait.

   // Wait for the task to finish.
   pData->signal.wait();
   

7. Удалите вызов CloseHandle.

8. Измените сигнатуру определения MyThreadFunction в соответствии с шагом 3.

   void __cdecl MyThreadFunction(LPVOID lpParam)
   

9. В конце функции MyThreadFunction вызовите метод Concurrency::event::set, чтобы сообщить главному приложению, что задача завершена.

   pData->signal.set();
   

10. Удалите оператор return из MyThreadFunction.

Пример

Описание

В следующем полном примере показан код, использующий упрощенную задачу для вызова функции MyThreadFunction.

Код

// migration-lwt.cpp
// compile with: /EHsc
#include <windows.h>
#include <tchar.h>
#include <strsafe.h>
#include <concrt.h>

using namespace Concurrency;

#define BUF_SIZE 255

void __cdecl MyThreadFunction(LPVOID param);

// Data structure for threads to use.
typedef struct MyData {
    int val1;
    int val2;
    event signal;
} MYDATA, *PMYDATA;

int _tmain()
{
   // Allocate memory for thread data.
   PMYDATA pData = (PMYDATA) HeapAlloc(GetProcessHeap(), 
      HEAP_ZERO_MEMORY, sizeof(MYDATA));

   if( pData == NULL )
   {
      ExitProcess(2);
   }

   // Set the values of the thread data.
   pData->val1 = 50;
   pData->val2 = 100;

   // Create the thread to begin execution on its own.
   CurrentScheduler::ScheduleTask(MyThreadFunction, pData);

   // Wait for the task to finish.
   pData->signal.wait();

   // Free memory allocation.
   HeapFree(GetProcessHeap(), 0, pData);

   return 0;
}

void __cdecl MyThreadFunction(LPVOID lpParam)
{
   PMYDATA pData = (PMYDATA)lpParam;

   // Use thread-safe functions to print the parameter values.

   TCHAR msgBuf[BUF_SIZE];
   StringCchPrintf(msgBuf, BUF_SIZE, TEXT("Parameters = %d, %d\n"), 
     pData->val1, pData->val2); 

   size_t cchStringSize;
   StringCchLength(msgBuf, BUF_SIZE, &cchStringSize);

   DWORD dwChars;
   WriteConsole(GetStdHandle(STD_OUTPUT_HANDLE), msgBuf, (DWORD)cchStringSize, &dwChars, NULL);

   pData->signal.set();
}

См. также

Ссылки

Класс Scheduler

Основные понятия

Планировщик задач (среда выполнения с параллелизмом)