您的位置:首页 > 编程语言 > C语言/C++

c++ 多线程中的线程同步--Event

2015-06-03 08:48 218 查看
 在上一篇 互斥量Mutex 与 互斥量CS 中,线程的编号,也就是i是在主线程中1的,但是子线程里打印出的 i 却非常混乱,因为主线程里的写操作 和子线程里的读操作是同时进行的,这个有点像数据库里的事物,写操作分为三个步骤,从内存中读取i的值放入寄存器,第二步在寄存器里加1,第三步写回内存,而子线程里的读都是从内存中读取的,可是这个时候,对i的加1操作可能已经进行了好几次了,子线程读到的i值根本不是当初生成它时候的那个值,说的普通点,你是一个子线程,住在南极,主线程住在北极,北极有一颗树,如今10岁了,也就是说它的年轮是10圈。主线程说你来吧,读取这颗树的年轮,这时你从南极前往北极,可是路途遥远,整整走了10年,于是你到达后读取年轮时发现居然是20圈,等你回到南极,又过了10年,你对身边的小伙伴说,北极有一颗树,年轮是20圈,但那是你读的时候,而今已经30圈了。互斥量和CS由于有线程所有权这个特质,所以只能用于做线程之间的互斥,但是没办法做线程间的同步,想要做同步,需要使用事件和信号量,今天先说说事件其实使用起来非常简单
#include <process.h>#include <iostream>#include <vector>#include"Lock.h"#include"WinTree.h"#include"A.h"using namespace std;int gNum;unsigned int __stdcall ThreadWrite(void *p);CriSection cs;HANDLE  g_hThreadEvent;int main(){const  int iCount = 50;HANDLE  handle[iCount];gNum = 0;g_hThreadEvent = CreateEvent(NULL,FALSE,FALSE,NULL);// 创建50个线程,每个线程中都会打印ifor(int i = 0;i<iCount;i++){handle[i] = (HANDLE)_beginthreadex(NULL, 0, ThreadWrite, &i, 0, NULL);// 一直等待WaitForSingleObject(g_hThreadEvent,INFINITE);}WaitForMultipleObjects(iCount, handle, TRUE, INFINITE);CloseHandle(g_hThreadEvent);return 1;}unsigned int __stdcall ThreadWrite(void *p){Lock lock(cs);int i = *(int*)p;SetEvent(g_hThreadEvent);Sleep(50);gNum++;cout<<"线程编号:"<<i<<"  全局变量:"<<gNum<<endl;return 0;}
主线程里想要给i加1,但是子线程说您先别着急,等我读取完了你再加,于是子线程先读取i的值,然后SetEvent,告诉主线程,OK,我已经读取完毕,你可以加1了,主线程一直在wait,终于等到了事件的触发,然后对i进行加1,这样一来,主线程在加1前,会先确定子线程是不是已经读取结束,如此,每个子线程都会获得属于自己的那个i
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: