学步园

#include <windows.h><br /> #include <iostream><br /> using namespace std;</p> <p>class CMySync<br /> {<br /> public:<br /> CMySync() { }<br /> virtual ~CMySync() { }</p> <p> virtual void Lock() { }<br /> virtual void Unlock() { }<br /> };</p> <p>class CMyCriticalSection : public CMySync<br /> {<br /> CRITICAL_SECTION m_cs;<br /> public:<br /> CMyCriticalSection() { InitializeCriticalSection(&m_cs); }<br /> virtual ~CMyCriticalSection() { DeleteCriticalSection(&m_cs); }</p> <p> virtual void Lock() { EnterCriticalSection(&m_cs); }<br /> virtual void Unlock() { LeaveCriticalSection(&m_cs); }<br /> };</p> <p>class CMyEvent : public CMySync<br /> {<br /> HANDLE m_hEvent;<br /> public:<br /> CMyEvent(LPSECURITY_ATTRIBUTES lpSA = NULL,LPCSTR lpName = NULL)<br /> {<br /> m_hEvent = CreateEvent(lpSA,FALSE,TRUE,lpName);<br /> }<br /> virtual ~CMyEvent()<br /> {<br /> if(m_hEvent) CloseHandle(m_hEvent);<br /> }</p> <p> virtual void Lock() { WaitForSingleObject(m_hEvent,INFINITE); }<br /> virtual void Unlock() { SetEvent(m_hEvent); }<br /> };</p> <p>class CMyMutex : public CMySync<br /> {<br /> HANDLE m_hMutex;<br /> public:<br /> CMyMutex(LPSECURITY_ATTRIBUTES lpSA = NULL,LPCSTR lpName = NULL)<br /> {<br /> m_hMutex = CreateMutex(lpSA,FALSE,lpName);<br /> }<br /> virtual ~CMyMutex()<br /> {<br /> if(m_hMutex) CloseHandle(m_hMutex);<br /> }</p> <p> virtual void Lock() { WaitForSingleObject(m_hMutex,INFINITE); }<br /> virtual void Unlock() { ReleaseMutex(m_hMutex); }<br /> };</p> <p>class CAutoSync<br /> {<br /> CMySync *m_pSync;<br /> public:<br /> CAutoSync(CMySync *pSync) : m_pSync(pSync)<br /> {<br /> m_pSync->Lock();<br /> }<br /> ~CAutoSync()<br /> {<br /> m_pSync->Unlock();<br /> }<br /> };</p> <p>int nTickets = 100;<br /> //CMyCriticalSection g_Sync;<br /> CMyCriticalSection *g_pSync = new CMyCriticalSection();</p> <p>DWORD WINAPI ThreadProc1(LPVOID lpParameter)<br /> {<br /> while(1)<br /> {<br /> //g_Sync.Lock();<br /> CAutoSync m_Sync(g_pSync);</p> <p> if(nTickets>0)<br /> cout<<"Thread1 sell ticket: "<<nTickets--<<endl;</p> <p> //g_Sync.Unlock();<br /> }<br /> }</p> <p>DWORD WINAPI ThreadProc2(LPVOID lpParameter)<br /> {<br /> while(1)<br /> {<br /> //g_Sync.Lock();<br /> CAutoSync m_Sync(g_pSync);</p> <p> if(nTickets>0)<br /> cout<<"Thread2 sell ticket: "<<nTickets--<<endl;</p> <p> //g_Sync.Unlock();<br /> }<br /> }</p> <p>void main(int argc,TCHAR*argv[])<br /> {<br /> HANDLE hThread1 = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ThreadProc1,NULL,0,NULL);<br /> HANDLE hThread2 = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ThreadProc2,NULL,0,NULL);<br /> CloseHandle(hThread1);<br /> CloseHandle(hThread2);</p> <p> Sleep(4000);<br /> }