前面的关于线程同步的两种方法都有讲解:
基于事件对象的:
http://www.cppblog.com/deercoder/archive/2010/02/09/107612.html基于互斥量的:
http://www.cppblog.com/deercoder/archive/2010/02/09/107606.html下面讲解第三种方法:基于临界区的方法:
代码:
#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;
}
实际上,这三种方法的实现都相同,只不过,所使用的函数不同而已,这里对于临界区的函数,就是对应的:
InitializeCriticalSection, DeleteCriticalSection, EnterCriticalSection, LeaveCriticalSection函数而已。
说说三者的区别吧:
基于互斥对象和事件对象的线程同步,属于内核对象,速度比较慢,不过可以在多个进程中的各个线程之间同步。
基于离你家而且的线程同步,属于用户方式下的,速度比较快,但是容易进入死锁状态!
这三种方法,都是可以实现Windows下面的线程同步,使得各个线程之间可以互通消息,实现交互式的访问。特别是对于共享资源的情况,必须要使用线程同步,否则会发生与时间有关的错误,前面的帖子中,列举出来的关于乱码和竞争的现象,输出信息的杂乱,都是说明了这一点。
在线程发生竞争的时候,也需要使用线程同步,否则,一旦发生与时间有关的错误,就会产生难以预料的BUG。对于实际编程的意义尤其重大!
在做完上面的这三种方法后,余下的就是基于信号量的,函数也不同,不再多说,如下:
#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 阅读(3087)
评论(0) 编辑 收藏 引用