window下线程同步之(Event Objects(事件)) / 事件CEvent的使用
篇一:http://www.cnblogs.com/staring-hxs/p/3666655.html
Event 方式是最具弹性的同步机制,因为他的状态完全由你去决定,不会像 Mutex 和 Semaphores 的状态会由类似:WaitForSingleObject 一类的函数的调用而改变,所以你可以精确的告诉 Event 对象该做什么事?以及什么时候去做!
HANDLE CreateEvent( LPSECURITY_ATTRIBUTES lpEventAttributes, BOOL bManualReset, BOOL bInitialState, LPCTSTR lpName // object name );
lpEventAttributes : 一个指向SECURITY_ATTRIBUTES结构的指针,确定返回的句柄是否可被子进程继承。如果lpEventAttributes是NULL,此句柄不能被继承。
bManualReset : 创建一个人工重置的事件(TRUE)使用ResetEvent()手动重置为无信号状态,
创建一个自动重置的事件(FALSE)。当一个等待线程被释放时,自动重置状态为无信号状态。
bInitialState : 用于指明该事件是要初始化为已通知状态(TRUE)还是未通知状态(FALSE)
bManualReset为TRUE时: 人工重置事件,当一个等待线程被释放时,必须使用ResetEvent()手动重置为无型号状态
当人工重置的事件得到通知时,等待该事件的所有线程均变为可调度线程。
bManualReset为FALSE时: 自动重置事件,当一个等待线程被释放时,自动重置状态为无信号状态
当自动重置的事件得到通知时,等待该事件的线程中只有一个线程变为可调度线程。
自动重置事件(通常没有必要为自动重置的事件调用ResetEvent函数)。
使用方法:
1、创建一个事件对象:CreateEvent;
2、打开一个已经存在的事件对象:OpenEvent;
3、获得事件的占有权:WaitForSingleObject 等函数(可能造成阻塞);
4、释放事件的占有权(设置为激发(有信号)状态,以让其他等待中的线程苏醒):SetEvent;
5、手动置为非激发(无信号)状态:ResetEvent
6、关闭事件对象句柄:CloseHandle;
固有特点(优点+缺点):
1、是一个系统核心对象,所以有安全描述指针,用完了要 CloseHandle 关闭句柄,这些是内核对象的共同特征;
2、因为是核心对象,所以执行速度稍慢(当然只是相比较而言);
3、因为是核心对象,而且可以命名,所以可以跨进程使用;
4、通常被用于 overlapped I/O 或被用来设计某些自定义的同步对象。
相关函数:
BOOL WINAPI SetEvent( __in HANDLE hEvent ); 把event对象设置为激活状态BOOL WINAPI ResetEvent( __in HANDLE hEvent ); 把event对象设置为非激活状态BOOL WINAPI PulseEvent( __in HANDLE hEvent ); 如果是一个人工重置事件:把event对象设置为激活状态,唤醒“所有”等待中的线程,然后event恢复为非激活状态 如果是一个自动重置事件:把event对象设置为激活状态,唤醒 “一个”等待中的线程,然后event恢复为非激活状态
下面主要演示一下采用CreateEvent实现线程同步。
例子很简单,主要测试CreateEvent中bManualReset 和 bInitialState 参数的取值在线程调用中信号状态的情况。
1、bManualReset:TRUE
bInitialState:TRUE
CreateEvent(NULL, TRUE, TRUE, NULL); //人工重置事件:使用手动重置为无信号状态,初始化时有信号状态
#include <iostream> #include <windows.h> using namespace std;DWORD WINAPI ThreadProc1(LPVOID lpParam); DWORD WINAPI ThreadProc2(LPVOID lpParam);HANDLE hEvent = NULL; HANDLE hThread1 = NULL; HANDLE hThread2 = NULL;int main(int argc, char *args[]) { hEvent = CreateEvent(NULL, TRUE, TRUE, NULL); //使用手动重置为无信号状态,初始化时有信号状态 hThread1 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadProc1, NULL, 0,NULL); hThread2 = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadProc2, NULL, 0,NULL); WaitForSingleObject( hThread1, INFINITE ); WaitForSingleObject( hThread2,INFINITE );return 0; } DWORD WINAPI ThreadProc1(LPVOID lpParam) {if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程1被调用!\n"; ResetEvent(hEvent);}return 0; } DWORD WINAPI ThreadProc2(LPVOID lpParam) { if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程2被调用!\n"; ResetEvent(hEvent);} return 0; }
2、bManualReset:TRUE
bInitialState:FALSE
CreateEvent(NULL, TRUE, FALSE, NULL);//人工重置事件:使用手动重置为无信号状态,初始化时为无信号状态
#include <iostream> #include <windows.h> using namespace std;DWORD WINAPI ThreadProc1(LPVOID lpParam); DWORD WINAPI ThreadProc2(LPVOID lpParam);HANDLE hEvent = NULL; HANDLE hThread1 = NULL; HANDLE hThread2 = NULL;int main(int argc, char *args[]) { hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); //使用手动重置为无信号状态,初始化时无信号状态 hThread1 = CreateThread(NULL, 0, ThreadProc1, NULL, 0,NULL); hThread2 = CreateThread(NULL, 0, ThreadProc2, NULL, 0,NULL); WaitForSingleObject( hThread1, INFINITE ); WaitForSingleObject( hThread2,INFINITE );return 0; } DWORD WINAPI ThreadProc1(LPVOID lpParam) {if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程1被调用!\n"; }return 0; } DWORD WINAPI ThreadProc2(LPVOID lpParam) { if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程2被调用!\n"; } return 0; }
当创建手动重置事件时初始化为无信号 hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); 得到的结果是:
在hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); 之后添加
SetEvent( hEvent );设置为有信号,因为bManualReset为TRUE时,等待该事件的所有线程均变为可调度线程
当我们在线程一中添加ResetEvent(hEvent);时运行程序发现线程1被调用,线程2没有被调用:
3、
bManualReset:FALSE
bInitialState:TRUE
CreateEvent(NULL, FALSE, TRUE, NULL); //自动重置事件:当一个等待线程被释放时,自动重置为无信号状态,初始是有信号状态
#include <iostream> #include <windows.h> using namespace std;DWORD WINAPI ThreadProc1(LPVOID lpParam); DWORD WINAPI ThreadProc2(LPVOID lpParam);HANDLE hEvent = NULL; HANDLE hThread1 = NULL; HANDLE hThread2 = NULL;int main(int argc, char *args[]) { hEvent = CreateEvent(NULL, FALSE, TRUE, NULL); //使用自动重置为无信号状态,初始化时有信号状态 hThread1 = CreateThread(NULL, 0, ThreadProc1, NULL, 0,NULL); hThread2 = CreateThread(NULL, 0, ThreadProc2, NULL, 0,NULL); WaitForSingleObject( hThread1, INFINITE ); WaitForSingleObject( hThread2,INFINITE );return 0; } DWORD WINAPI ThreadProc1(LPVOID lpParam) {if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程1被调用!\n"; } return 0; } DWORD WINAPI ThreadProc2(LPVOID lpParam) { if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程2被调用!\n"; } return 0; }
从结果可以看到线程1被调用,线程2一直在等待。由于CreateEvent(NULL, FALSE, TRUE, NULL)//使用自动重置为无信号状态,初始化时有信号状态
所以当线程1执行的时候hEvent是有信号的,线程1正常运行,又由于bManualReset为FALSE时:当一个等待线程被释放时,自动重置状态为无信号状态
因此线程2一直在等待,由于主线程加了WaitForSingleObject( hThread2,INFINITE ); 所以主线程也在一直等待
4、
bManualReset:FALSE
bInitialState:FALSE
CreateEvent(NULL, FALSE, FALSE, NULL);//自动重置事件:线程释放后自动重置为无信号状态,初始化时为无信号状态
#include <iostream> #include <windows.h> using namespace std;DWORD WINAPI ThreadProc1(LPVOID lpParam); DWORD WINAPI ThreadProc2(LPVOID lpParam);HANDLE hEvent = NULL; HANDLE hThread1 = NULL; HANDLE hThread2 = NULL;int main(int argc, char *args[]) { hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); //使用自动重置为无信号状态,初始化时无信号状态 SetEvent(hEvent);hThread1 = CreateThread(NULL, 0, ThreadProc1, NULL, 0,NULL); hThread2 = CreateThread(NULL, 0, ThreadProc2, NULL, 0,NULL); WaitForSingleObject( hThread1, INFINITE ); WaitForSingleObject( hThread2,INFINITE );return 0; } DWORD WINAPI ThreadProc1(LPVOID lpParam) {if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程1被调用!\n"; } return 0; } DWORD WINAPI ThreadProc2(LPVOID lpParam) { if ( WAIT_OBJECT_0 == WaitForSingleObject(hEvent,INFINITE) ) { cout <<"线程2被调用!\n"; } return 0; }
由于CreateEvent(NULL, FALSE, FALSE, NULL);//使用手动重置为无信号状态,初始化时为无信号状态
由于调用SetEvent,hEvent为有信号状态,线程1正常执行,又由于bManualReset为FALSE时: 当一个等待线程被释放时,自动重置状态为无信号状态,调用完线程1后,hEvent自动重置为无信号状态,所以线程2只能在等待
CEvent类的一个对象,表示一个“事件”——一个允许一个事件发生时线程通知另一个线程的同步对象。在一个线程需要了解何时执行任务时,事件是十分有用的。例如,拷贝数据到数据文档时,线程应被通知何时数据是可用的。当新数据可用时,通过运用CEvent对象来通知拷贝线程,线程才可能尽快地执行。例如在某些网络应用程序中,一个线程(记为A)负责监听通信端口,另一个线程(记为B)负责更新用户数据。通过使用CEvent类,线程A可以通知线程B何时更新用户数据,这样线程B可以尽快地更新用户数据。
CEvent对象有两种类型:自动和手工。一个手工CEvent对象存在于由ResetEvent或SetEvent设置的状态中,直到另一个函数被调用。一个自动CEvent对象在至少一个线程被释放后自动返回一个无标记(无用的)状态。
要使用一个CEvent对象,应在需要时构造一个CEvent对象。指定要等待的事件,应用应拥有它,就可以在构造函数返回时访问事件。调用SetEvent标记(使可用)事件对象,然后当访问完控制资源时,调用Unlock函数。
另一个使用CEvent对象的方法是添加一个CEvent类型的变量,使之成为希望控制的类的一个数据成员。在控制对象被构造期间,可调用CEvent数据成员的构造函数,它指明时间是否是最初就被标记、需要的事件对象类型、事件名称(如果在进程中要使用)和所希望的安全属性。
CEvent类的构造函数原型如下:
BOOL bInitiallyOwn /* = FALSE */ , //用来指定事件对象初始状态是否为发信状态(默认值为未发信)
BOOL bManualReset /* = FALSE */ , //用来指定创建的事件对象是自动事件还是手动事件对象(默认值为自动事件对象)
LPCTSTR lpszNAme /* = NULL */ , //用来定义事件对象的名称
LPSECURITY_ATTRIBUTES lpsaAttribute /* = NULL */ //指向一个LPSECURITY_ATTRIBUTES结构的指针
)
CEvent类提供的三种方法
PulseEvent() //设置事件为发信状态,并释放其他正在等待的线程,然后把事件设置为未发信状态
ResetEvent() //设置事件为未发信状态
1.自动事件对象
如果使用CEvent类构造函数的默认参数值的话,则定义的对象为自动事件对象。初始状态为未发信状态,可以用SetEvent使之变为发信状态,等待线程中的第一个线程恢复运行,但事件对象会随即自动将其变为未发信状态,从而使其他处于等待状态的线程仍然被阻塞。就是说,自动事件对象一次只能启动一个处于等待状态的线程。
示例:一个应用程序,当用户在程序窗口上按下鼠标左键时,会创建和启动两个线程,这两个线程被启动后,各自显示一个信息框,表明线程已被启动,随即被事件对象的Lock函数把线程挂起。当用户在程序窗口按下鼠标右键时,启动另一个线程,在该线程中把事件对象置为“发信”状态,从而启动了第一个被挂起的线程。
1.新建单文档程序;
2.在视图类的实现文件中定义一个全局事件对象:
3.在视图类的实现文件编写如下线程函数:
{
LPTSTR pMessage=_T( "Thread1 is started" );
CWnd* pMainWnd=AfxGetMainWnd();
::MessageBox(pMainWnd->m_hWnd,pMessage,_T( "Thread message" ),MB_OK);
eventObj.Lock(); //线程1处于等待状态
/*-----------------------------------------------------------------*/
pMessage=_T( "Thread1 is unblocked" );
::MessageBox(pMainWnd->m_hWnd,pMessage,_T( "Thread1 message" ),MB_OK); //显示线程1解锁后的信息框
eventObj.Lock(); //线程1再次处于等待状态
/*-----------------------------------------------------------------*/
pMessage=_T( "Thread1 is unblocked again" );
::MessageBox(pMainWnd->m_hWnd,pMessage,_T( "Thread1 message" ),MB_OK); //显示线程1解锁后的信息框
return 0 ;
}
UINT MessageThread2(LPVOID pParam)
{
LPTSTR pMessage=_T( "Thread2 is started" );
CWnd* pMainWnd=AfxGetMainWnd();
::MessageBox(pMainWnd->m_hWnd,pMessage,_T( "Thread message" ),MB_OK);
eventObj.Lock(); //线程2处于等待状态
/*-----------------------------------------------------------------*/
pMessage=_T( "Thread2 is unblocked" );
::MessageBox(pMainWnd->m_hWnd,pMessage,_T( "Thread2 message" ),MB_OK); //显示线程2解锁后的信息框
return 0 ;
}
UINT MessageThread3(LPVOID pParam)
{
eventObj.SetEvent(); //把事件对象置为发信状态
return 0 ;
}
4.视图类的鼠标响应消息如下:
{
AfxBeginThread(MessageThread1, _T( "Thread is started" )); //启动线程1
AfxBeginThread(MessageThread2, _T( "Thread is started" )); //启动线程2
CView::OnLButtonDown(nFlags, point);
}
void CThreadTestView::OnRButtonDown(UINT nFlags, CPoint point)
{
AfxBeginThread(MessageThread3, _T( "Thread is unblocked" )); //启动线程3
CView::OnRButtonDown(nFlags, point);
}
程序运行结果:
2.手工事件对象
手工事件对象一旦用函数SetEvent设置为“发信”状态,就一直处于有效状态,除非又使用对象的成员函数PulseEvent或ResetEvent把它重新设置为“未发信”状态。所以手工事件对象被用来恢复多个处在等待状态线程的运行。
示例:把上面的例子的事件对象定义为手工事件对象,然后运行该程序。
修改为下面代码:
CEvent eventObj(FALSE,TRUE);
程序运行结果:
参考资料:
1.CEvent类详解:http://www.360doc.com/content/10/0411/04/896768_22478483.shtml
2.CEvent百科:http://baike.baidu.com/view/2894213.htm
3.事件(CEvent)——MFC:http://blog.sina.com.cn/s/blog_627ebfc30100iu7k.html
window下线程同步之(Event Objects(事件)) / 事件CEvent的使用相关推荐
- VC++中多线程学习(MFC多线程)三(线程同步包含:原子互锁、关键代码段、互斥器Mutex、Semaphores(信号量)、Event Objects(事件))
目录 线程同步的必要性: 2.解决同步问题的方法 2.1原子互锁家族函数 2.2Critical Sections(关键代码段.关键区域.临界区域) 2.3 互斥器Mutex ...
- Window下线程与线程同步总结
目录 一 线程创建与使用 线程创建函数 CreateThread与_beginthreadex 等待函数 WaitForSingleObject 和 WaitForMultipleObjects 例程 ...
- 【Window】线程同步概述
第一节:[Window]创建线程的3种方式 第二节:[Window]线程同步概述 第三节:[Window]线程同步方式1--临界区(关键代码段) 第四节:[Window]线程同步方式2--互斥量 第五 ...
- 【Window】线程同步方式1——临界区(关键代码段)
第一节:[Window]创建线程的3种方式 第二节:[Window]线程同步概述 第三节:[Window]线程同步方式1--临界区(关键代码段) 第四节:[Window]线程同步方式2--互斥量 第五 ...
- 孤荷凌寒自学python第四十一天python的线程同步之Event对象
孤荷凌寒自学python第四十一天python的线程同步之Event对象 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) 鉴于Lock锁与RLock锁均宣告没有完全完成同步文件操作的问题,于是 ...
- WINDOWS下线程同步探讨
本文主要讨论WINDOWS应用层编程的线程同步问题.在实际编程过程中,我们经常会遇到线程同步的问题,例如在编写多线程共同访问一个共享资源的程序时,如果多个线程只是读取资源那么就不会涉及到下面我们要讨论 ...
- windows下线程同步的常见方法:CreateEvent和SetEvent及WaitForSingleObject windows下常见锁的实现 EnterCriticalSection
windows下我们常用的线程同步的方法是 事件 首先介绍CreateEvent是创建windows事件的意思,作用主要用在判断线程退出,程锁定方面. CreateEvent 函功能描述:创建或打 ...
- linux使用线程实现生产者消费者问题,Linux平台下线程同步,实现“生产者消费者问题”...
(1)线程同步,实现"生产者消费者问题" 要求:缓冲区大小为20,生产者每次放一个产品,消费者每次取走一个产品:生产者和消费者至少2个. (2)代码如下: #include #in ...
- 【转】1.3异步编程:线程同步基元对象
开始<异步编程:同步基元对象(上)> 示例:异步编程:线程同步基元对象.rar 如今的应用程序越来越复杂,我们常常需要多线程技术来提高我们应用程序的响应速度.每个线程都由自己的线程ID,当 ...
最新文章
- QC数据库恢复,解决SQL孤立用户问题
- 数据库的事务隔离技术 之 MVCC
- CTO 和你唠唠,这 7 个团队都在干啥 | 神策招人记
- android导航屏幕,发现具有软件导航栏的Android设备的真实屏幕尺寸(以像素为单位)...
- html 天气特效,用CSS制作天气特效动画,源码分享
- linux开启IOMMU方法
- pytorch visdom可视化工具学习—1—详细使用-3-Generic Plots和Others
- 查看opencv版本
- Google开发者账号申请
- 用matlab计算矩阵的权重,如何使用matlab计算加权平均分
- 老MacBook升级内存记
- 【数据分析实战】北京租房数据统计分析
- CIM是什么?CIM智慧城市建设路径分析
- php判断百度蜘蛛ip,判断百度蜘蛛偷偷进行301转移权重 给新站提权
- 使用 spacy 进行自然语言处理(一)
- NEO FANTASY:回合制策略游戏在ACGN文化与GameFi中的新探索09-07
- 单例设计模式(饿汉式VS懒汉式)
- 【Mqtt】基于paho.mqtt.c库的mqtt客户端实现
- windows11切换输入法的快捷键是什么?win11怎样修改输入法快捷键
- 无聊写着玩:解二阶线性微分方程