|
| БЕСПЛАТНАЯ ежедневная online лотерея! Выигрывай каждый день БЕСПЛАТНО! |
|
|
Using Thread Local Storage
Thread local storage (TLS) enables multiple threads of the same process to use an index allocated by the TlsAlloc function to store and retrieve a value that is local to the thread. In this example, an index is allocated when the process starts. When each thread starts, it allocates a block of dynamic memory and stores a pointer to this memory by using the TLS index. The TLS index is used by the locally defined CommonFunc function to access the data local to the calling thread. Before each thread terminates, it releases its dynamic memory.
#include #include #define THREADCOUNT 4 DWORD dwTlsIndex; VOID ErrorExit(LPTSTR); VOID CommonFunc(VOID) { LPVOID lpvData; // Retrieve a data pointer for the current thread. lpvData = TlsGetValue(dwTlsIndex); if ((lpvData == 0) && (GetLastError() != 0)) ErrorExit("TlsGetValue error"); // Use the data stored for the current thread. printf("common: thread %d: lpvData=%lx\n", GetCurrentThreadId(), lpvData);
Sleep(5000); } DWORD WINAPI ThreadFunc(VOID) { LPVOID lpvData; // Initialize the TLS index for this thread. lpvData = (LPVOID) LocalAlloc(LPTR, 256); if (! TlsSetValue(dwTlsIndex, lpvData)) ErrorExit("TlsSetValue error"); printf("thread %d: lpvData=%lx\n", GetCurrentThreadId(), lpvData); CommonFunc(); // Release the dynamic memory before the thread returns. lpvData = TlsGetValue(dwTlsIndex); if (lpvData != 0)
LocalFree((HLOCAL) lpvData); return 0; } DWORD main(VOID) { DWORD IDThread; HANDLE hThread[THREADCOUNT]; int i; // Allocate a TLS index. if ((dwTlsIndex = TlsAlloc()) == 0xFFFFFFFF) ErrorExit("TlsAlloc failed"); // Create multiple threads. for (i = 0; i < THREADCOUNT; i++) { hThread[i] = CreateThread(NULL, // no security attributes 0, // use default stack size
(LPTHREAD_START_ROUTINE) ThreadFunc, // thread function NULL, // no thread function argument 0, // use default creation flags &IDThread); // returns thread identifier // Check the return value for success. if (hThread[i] == NULL) ErrorExit("CreateThread error\n"); } for (i = 0; i < THREADCOUNT; i++) WaitForSingleObject(hThread[i], INFINITE);
return 0; } VOID ErrorExit (LPTSTR lpszMessage) { fprintf(stderr, "%s\n", lpszMessage); ExitProcess(0); }
| Пригласи друзей и счет твоего мобильника всегда будет положительным! |
| Пригласи друзей и счет твоего мобильника всегда будет положительным! |
Использование Локального Хранения Резьбы
Заправьте локальное хранение (TLS) допустимую многочисленную резьбу того же самого процесса, чтобы использовать индекс распределенный функцией TlsAlloc, чтобы хранить и извлекать величину, которая локальная в резьбе. В этом примере, индекс распределен когда процесс начинается. Когда каждая резьба начинается, она распределяет блока динамической памяти и хранит указатель в эту память используя индекс TLS. Индекс TLS использован локально определенной функцией CommonFunc, чтобы иметь доступ к данным локальным к вызову резьбы. Прежде, чем каждая резьба завершится, она выпускает свою динамическую память.
#include #include #define THREADCOUNT 4 DWORD dwTlsIndex; АННУЛИРУЙТЕ ErrorExit(LPTSTR); ПУСТОТА CommonFunc(ПУСТОТА) { LPVOID lpvData; // Извлеките указатель данных для текущей резьбы. lpvData = TlsGetValue(dwTlsIndex); если ((lpvData == 0) && (GetLastError() != 0)) ErrorExit(ошибка "TlsGetValue"); // Использование данные загружались для текущей резьбы. printf("common: резьба %d: lpvData=%lx\n", GetCurrentThreadId(), lpvData);
Спать(5000); } DWORD WINAPI ThreadFunc(ПУСТОТА) { LPVOID lpvData; // Инициализируйте индекс TLS для этой резьбы. lpvData = (LPVOID) LocalAlloc(LPTR, 256); если (! TlsSetValue(dwTlsIndex, lpvData)) ErrorExit(ОШИБКА "TlsSetValue"); printf("thread %d: lpvData=%lx\n", GetCurrentThreadId(), lpvData); CommonFunc(); // Версия динамическая память прежде, чем резьба возвращается. lpvData = TlsGetValue(dwTlsIndex); если (lpvData != 0)
LocalFree((HLOCAL) lpvData); возврат 0; } ОСНОВА DWORD(ПУСТОТА) { DWORD IDThread; ПРООПЕРИРУЙТЕ hThread[THREADCOUNT]; int i; // Распределите индекс TLS. если ((dwTlsIndex = TlsAlloc()) == 0xFFFFFFFF) ErrorExit("TlsAlloc потерпевший неудачу"); // Создайте многочисленную резьбу. для (i = 0; я < THREADCOUNT; я++) { hThread[i] = CreateThread(НЕДЕЙСТВИТЕЛЬНАЯ, // никакая безопасность не приписывает 0, // размер по умолчанию стека использования
(LPTHREAD_START_ROUTINE) ThreadFunc, // резьба функциональный НЕДЕЙСТВИТЕЛЬНЫЙ, // никакой функциональный аргумент резьбы 0, // флаги по умолчанию создания использования &IDThread); // возврат заправляет идентификатор // Проверьте обратную величину на наличие успеха. если (hThread[i] == НЕДЕЙСТВИТЕЛЬНЫЙ) ErrorExit("CreateThread error\n"); } для (i = 0; я < THREADCOUNT; я++) WaitForSingleObject(hThread[i], БЕСКОНЕЧНЫЙ);
возврат 0; } ПУСТОТА ErrorExit (lpszMessage LPTSTR) { fprintf(stderr, "%s\n", lpszMessage); ExitProcess(0); }
|
|
|
|
| |