- 01
- 02
- 03
- 04
- 05
- 06
- 07
- 08
- 09
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
#ifdef WIN32
typedef DWORD (*LPTHREAD_METHOD)(LPVOID pParam);
// Структура параметров для статической функции.
typedef struct STARTUP_PARAM
{
// MSVThread* pClass;
LPTHREAD_METHOD pMethod;
LPVOID pParam;
} *LPSTARTUP_PARAM;
// Функция, которая создает новый поток.
HANDLE StartThread (LPTHREAD_METHOD pMethod, LPVOID pParam=0,
LPDWORD pdwThreadID = NULL,
LPSECURITY_ATTRIBUTES pSecurity = NULL ,
DWORD dwStackSize = 0 ,
DWORD dwFlags = 0);
// Статическая функция, которая запустит метод.
static DWORD StartFunc (LPSTARTUP_PARAM pStartup);
HANDLE StartThread(LPTHREAD_METHOD pMethod, LPVOID pParam,
LPDWORD pdwThreadID /* = NULL */,
LPSECURITY_ATTRIBUTES pSecurity /* = NULL */,
DWORD dwStackSize /* = 0 */,
DWORD dwFlags /* = 0 */)
{
// Создаем структуру и упаковываем данные для статической функции.
LPSTARTUP_PARAM pStartup = new STARTUP_PARAM;
pStartup->pMethod = pMethod;
pStartup->pParam = pParam;
// Создаем новый поток.
return CreateThread(pSecurity, dwStackSize, (LPTHREAD_START_ROUTINE)StartFunc, pStartup, dwFlags, pdwThreadID);
}
// В новом потоке вначале вызывается функция CMyClass::StartFunc(...)
// А она запускает наш метод.
DWORD StartFunc(LPSTARTUP_PARAM pStartup)
{
// Распаковываем данные в новом потоке.
// Получаем указатель на класс и на метод класса.
LPTHREAD_METHOD pMethod = pStartup->pMethod;
LPVOID pParam = pStartup->pParam;
// Запускаем метод класса в новом потоке.
DWORD dwResult = (*pMethod)(pParam);
// Удаляем временные данные и возвращаем код возврата из нового потока.
delete pStartup;
return dwResult;
}
#else
#include "pthread.h"
typedef DWORD (*LPTHREAD_METHOD)(LPVOID pParam);
// Структура параметров для статической функции.
typedef struct STARTUP_PARAM
{
LPTHREAD_METHOD pMethod;
LPVOID pParam;
} *LPSTARTUP_PARAM;
// Статическая функция, которая запустит метод.
static DWORD StartFunc (LPSTARTUP_PARAM pStartup);
// Функция, которая создает новый поток.
HANDLE StartThread(LPTHREAD_METHOD pMethod, LPVOID pParam=0,
LPDWORD pdwThreadID=0 /* = NULL */,
// LPSECURITY_ATTRIBUTES pSecurity /* = NULL */,
// DWORD dwStackSize /* = 0 */,
const pthread_attr_t* dwFlags=0 /* = 0 */)
{
// Создаем новый поток.
pthread_t restrict;
if(pthread_create(&restrict, dwFlags, (void* (*)(void*))pMethod, pParam)) return pdwThreadID;
return 0;
}
#endif
Человек пишет кросплатформенный http-сервер, а заодно свой собсвенный фреймворк. Участок кода с нитями.
Follow us!