用关键段和event使得两个子线程交替输出1,2,3,4,5
#include "Job.h" #include <process.h> //#include "Thread.h" //#include "Synchronization.h" int g_t=0; HANDLE g_hThreadEvent1; CRITICAL_SECTION g_csThreadCode1; HANDLE event0; HANDLE event1; unsigned int __stdcall testFun1(void* pPM) { int nThreadID=*(int *)pPM; SetEvent(g_hThreadEvent1); Sleep(50); for(int i=0;i<10;++i) { if(nThreadID==0) { WaitForSingleObject(event0,INFINITE); } else WaitForSingleObject(event1,INFINITE); EnterCriticalSection(&g_csThreadCode1); if(nThreadID==0) { //阻塞当前线程 激活另外一个线程 ResetEvent(event0); SetEvent(event1); } else { ResetEvent(event1); SetEvent(event0); } cout<<"ID:"<<nThreadID<<"---"<<"值为:"<<g_t++<<endl; LeaveCriticalSection(&g_csThreadCode1); } return 0; } int main() { g_hThreadEvent1=CreateEvent(NULL,FALSE,FALSE,NULL); event0=CreateEvent(NULL,FALSE,FALSE,NULL); event1=CreateEvent(NULL,FALSE,TRUE,NULL); InitializeCriticalSection(&g_csThreadCode1); HANDLE handle[2]; int i=0; while(i<2) { handle[i]=(HANDLE)_beginthreadex(NULL,0,testFun1,&i,0,NULL); WaitForSingleObject(g_hThreadEvent1,INFINITE); i++; } WaitForMultipleObjects(2,handle,TRUE,INFINITE); CloseHandle(g_hThreadEvent1); DeleteCriticalSection(&g_csThreadCode1); for(i=0;i<2;i++) CloseHandle(handle[i]); CloseHandle(event0); CloseHandle(event1); return 0; }
截图: