window下线程同步之(Event Objects(事件))的具体使用和说明
2015-12-16 15:34
573 查看
window下线程同步之(Event Objects(事件))
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只能在等待
相关文章推荐
- objective-C语言_面向对象(多态)
- SAP NUMBER RANGE维护配置object FBN1 Deletion only possible if status is initial
- Objective-C语言_面向对象(继承)
- Objective-C语言_面向对象(封装)
- setValue和setObject的区别
- Objective-C语言_点语法和@property
- Thymeleaf中的context对象-原标题:Context Objects in Thymeleaf
- Objective-C语言_便利初始化函数和便利构造器
- Objective-C_OC中的方法
- Objective-C语言-对象
- Objective-c语言_实例方法和类方法的区别
- 【web前端】typeof和object.toString.call()的区别
- Objective-c语言_可变字典
- Objective-c语言_不可变字典
- Objective-c语言_数组练习题2:
- Objective-c语言_数组练习题1
- Objective-C语言——NSMutableDictionary可变字典
- Objective-C语言——NSDictionary不可变字典
- Object-C 中各数据类型转换 NSData转NSString,Byte,UIImage
- object-c画笔的简单实现