QueueUserWorkItem 初步学习

大家好，又见面了，我是你们的朋友全栈君。

DWORD WINAPI TestThreadPool(PVOID pContext);

CRITICAL_SECTION g_cs;

int _tmain(int argc, _TCHAR* argv[]) { InitializeCriticalSection(&g_cs); SECURITY_ATTRIBUTES sa; sa.bInheritHandle = TRUE; sa.nLength = sizeof(SECURITY_ATTRIBUTES); sa.lpSecurityDescriptor = NULL;

HANDLE hSemaphore = CreateSemaphoreW(&sa, 0 ,1, L”jyytet”);

for (int i = 0; i < 10; i++) { QueueUserWorkItem(TestThreadPool, L”Hello World”, WT_EXECUTEDEFAULT); } QueueUserWorkItem(TestThreadPool, L”Finish”, WT_EXECUTEDEFAULT);

WaitForSingleObject(hSemaphore, -1); CloseHandle(hSemaphore); hSemaphore = NULL; DeleteCriticalSection(&g_cs);

wprintf(L”Game over /r/n”); getchar(); return 0; }

DWORD WINAPI TestThreadPool(PVOID pContext) { if (NULL == pContext) return 0;

EnterCriticalSection(&g_cs); wchar_t *pPrintf = (wchar_t *) pContext; wprintf(L”%s /r/n”, pPrintf); Sleep(1000); if (wcscmp(pPrintf, L”Finish”) == 0) { HANDLE hSemaphore = OpenSemaphoreW(SEMAPHORE_ALL_ACCESS, FALSE, L”jyytet”); assert(hSemaphore != NULL); ReleaseSemaphore(hSemaphore, 1, NULL); CloseHandle(hSemaphore); } LeaveCriticalSection(&g_cs);

return 1; }

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/193166.html原文链接：https://javaforall.cn