随笔-145  评论-173  文章-70  trackbacks-0
前面的关于线程同步的两种方法都有讲解:

基于事件对象的: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 阅读(3066) 评论(0)  编辑 收藏 引用

只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理