前面的關(guān)于線程同步的兩種方法都有講解：
基于事件對象的：
http://m.shnenglu.com/deercoder/archive/2010/02/09/107612.html基于互斥量的：
http://m.shnenglu.com/deercoder/archive/2010/02/09/107606.html下面講解第三種方法：基于臨界區(qū)的方法：
代碼：
#include <windows.h>
#include <iostream>
using namespace std;
DWORD WINAPI Fun1Proc(LPVOID param);
DWORD WINAPI Fun2Proc(LPVOID param);
int time = 0;
CRITICAL_SECTION critical;
void main()
{
HANDLE thread1,thread2;
thread1 = CreateThread(NULL,0,Fun1Proc,NULL,0,NULL);
thread2 = CreateThread(NULL,0,Fun2Proc,NULL,0,NULL);
CloseHandle(thread1);
CloseHandle(thread2);
InitializeCriticalSection(&critical);
Sleep(4000);
DeleteCriticalSection(&critical);
}
DWORD WINAPI Fun1Proc(LPVOID param)
{
while(1)
{
EnterCriticalSection(&critical);
if(time <= 20)
{
Sleep(1);
cout << "子線程1第" << time ++ << "次"<< endl;
}
else
break;
LeaveCriticalSection(&critical);
}
return 0;
}
DWORD WINAPI Fun2Proc(LPVOID param)
{
while(1)
{
EnterCriticalSection(&critical);
if(time <= 20)
{
Sleep(1);
cout << "子線程2第" << time ++ << "次" << endl;
}
else
break;
LeaveCriticalSection(&critical);
}
return 0;
}
實(shí)際上，這三種方法的實(shí)現(xiàn)都相同，只不過，所使用的函數(shù)不同而已，這里對于臨界區(qū)的函數(shù)，就是對應(yīng)的：
InitializeCriticalSection, DeleteCriticalSection, EnterCriticalSection, LeaveCriticalSection函數(shù)而已。
說說三者的區(qū)別吧：
基于互斥對象和事件對象的線程同步，屬于內(nèi)核對象，速度比較慢，不過可以在多個(gè)進(jìn)程中的各個(gè)線程之間同步。
基于離你家而且的線程同步，屬于用戶方式下的，速度比較快，但是容易進(jìn)入死鎖狀態(tài)！
這三種方法，都是可以實(shí)現(xiàn)Windows下面的線程同步，使得各個(gè)線程之間可以互通消息，實(shí)現(xiàn)交互式的訪問。特別是對于共享資源的情況，必須要使用線程同步，否則會發(fā)生與時(shí)間有關(guān)的錯(cuò)誤，前面的帖子中，列舉出來的關(guān)于亂碼和競爭的現(xiàn)象，輸出信息的雜亂，都是說明了這一點(diǎn)。
在線程發(fā)生競爭的時(shí)候，也需要使用線程同步，否則，一旦發(fā)生與時(shí)間有關(guān)的錯(cuò)誤，就會產(chǎn)生難以預(yù)料的BUG。對于實(shí)際編程的意義尤其重大！
在做完上面的這三種方法后，余下的就是基于信號量的，函數(shù)也不同，不再多說，如下：
#include <windows.h>
#include <iostream>
using namespace std;
DWORD WINAPI Fun1Proc(LPVOID param);
DWORD WINAPI Fun2Proc(LPVOID param);
int time = 0;
HANDLE sema;
void main()
{
HANDLE thread1,thread2;
thread1 = CreateThread(NULL,0,Fun1Proc,NULL,0,NULL);
thread2 = CreateThread(NULL,0,Fun2Proc,NULL,0,NULL);
CloseHandle(thread1);
CloseHandle(thread2);
sema = CreateSemaphore(NULL,1,1,NULL);
Sleep(4000);
}
DWORD WINAPI Fun1Proc(LPVOID param)
{
while(1)
{
WaitForSingleObject(sema,INFINITE);
if(time <= 20)
{
Sleep(1);
cout << "子線程1第" << time ++ << "次"<< endl;
}
else
break;
ReleaseSemaphore(sema,1,NULL);
}
return 0;
}
DWORD WINAPI Fun2Proc(LPVOID param)
{
while(1)
{
WaitForSingleObject(sema,INFINITE);
if(time <= 20)
{
Sleep(1);
cout << "子線程2第" << time ++ << "次" << endl;
}
else
break;
ReleaseSemaphore(sema,1,NULL);
}
return 0;
}
posted on 2010-02-09 19:15
deercoder 閱讀(3111)
評論(0) 編輯 收藏 引用