code/test_code/threadtest/main.cpp at master · lufb/code

History

66 lines (48 loc) · 1.45 KB

Raw

#include <stdio.h>

#include <process.h>

#include <winsock2.h>

#define MAX_THREAD 64 /** 最大线程个数*/

#define INIT_THREAD_COUNT 5 /** 初始化时创建的工作线程个数*/

bool Global_run = true;

typedef struct _THREAD_POOL_MGR_

{

CRITICAL_SECTION thrPooLock;

unsigned char curThreadCount;

//bool handleUsed[MAX_THREAD];

HANDLE pThread[MAX_THREAD]; /** != NULL:isused*/

}THREAD_POOL_MGR;

THREAD_POOL_MGR Global_ThrMgr;

unsigned int WINAPI threadPoolMgr1(LPVOID lpParameter)

{

Sleep(20000);

printf("1 returned\n");

return 1;

}

unsigned int WINAPI threadPoolMgr2(LPVOID lpParameter)

{

Sleep(5000);

printf("2 returned\n");

return 2;

}

unsigned int WINAPI threadPoolMgr3(LPVOID lpParameter)

{

Sleep(10000);

printf("3 returned\n");

return 3;

}

int main()

{

HANDLE hThread[12] = {NULL};

int ret;

hThread[1] = (void *)_beginthreadex(NULL, 0, threadPoolMgr1, NULL, 0, NULL);//20

hThread[0] = (void *)_beginthreadex(NULL, 0, threadPoolMgr2, NULL, 0, NULL);//5

hThread[2] = (void *)_beginthreadex(NULL, 0, threadPoolMgr3, NULL, 0, NULL);//10

Sleep(7000);

/** Note:等待所有线程退出时，第一个参数与第二个参数都要有效才可达到预期的效果*/

ret = WaitForMultipleObjects(3, hThread, true, INFINITE);

printf("main thread 0 wait return[%d] Error[%d]\n", ret, GetLastError());

ret = WaitForMultipleObjects(3, hThread, true, INFINITE);

printf("main thread 0 wait return[%d] Error[%d]\n", ret, GetLastError());

Sleep(22000);

return 0;

}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Expand file tree

Search code, repositories, users, issues, pull requests...

FilesExpand file tree

main.cpp

Latest commit

History

main.cpp

File metadata and controls

Expand file tree