VC++ 线程同步之事件对象(event)
Event是windows操作系统的一种内核对象,它可以用于进程间同步和线程间同步。
Event 方式是最具弹性的同步机制,因为他的状态完全由你去决定,不会像 Mutex 和 Semaphores 的状态会由类似:WaitForSingleObject 一类的函数的调用而改变,所以你可以精确的告诉 Event 对象该做什么事?以及什么时候去做!
固有特点(优点+缺点):
1、是一个系统核心对象,所以有安全描述指针,用完了要 CloseHandle 关闭句柄,这些是内核对象的共同特征;
2、因为是核心对象,所以执行速度稍慢(当然只是相比较而言);
3、因为是核心对象,而且可以命名,所以可以跨进程使用;
4、通常被用于 overlapped I/O 或被用来设计某些自定义的同步对象。
相关函数
复制代码
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函数)。BOOL WINAPI SetEvent( __in HANDLE hEvent ); 把event对象设置为激活状态BOOL WINAPI ResetEvent( __in HANDLE hEvent ); 把event对象设置为非激活状态BOOL WINAPI PulseEvent( __in HANDLE hEvent ); 如果是一个人工重置事件:把event对象设置为激活状态,唤醒“所有”等待中的线程,然后event恢复为非激活状态
如果是一个自动重置事件:把event对象设置为激活状态,唤醒 “一个”等待中的线程,然后event恢复为非激活状态
示例代码
1、创建一个事件对象:CreateEvent;
2、打开一个已经存在的事件对象:OpenEvent;
3、获得事件的占有权:WaitForSingleObject 等函数(可能造成阻塞);
4、释放事件的占有权(设置为激发(有信号)状态,以让其他等待中的线程苏醒):SetEvent;
5、手动置为非激发(无信号)状态:ResetEvent
6、关闭事件对象句柄:CloseHandle;
下面是使用Win32 API的Event对象实现线程同步的C++代码:
#include <iostream>
#include <windows.h> using namespace std; HANDLE g_hEvent; // 全局的事件对象 DWORD WINAPI ThreadProc(LPVOID lpParam)
{ WaitForSingleObject(g_hEvent, INFINITE); // 这里是需要同步的代码 cout << "Thread " << lpParam << " is running." << endl; return 0;
} int main()
{ g_hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); HANDLE hThread[3]; for (int i = 0; i < 3; i++) { hThread[i] = CreateThread(NULL, 0, ThreadProc, (LPVOID)i, 0, NULL); if (hThread[i] == NULL) { cout << "Thread " << i << " failed to create." << endl; } } // 设置事件对象,允许线程执行 SetEvent(g_hEvent); WaitForMultipleObjects(3, hThread, TRUE, INFINITE); CloseHandle(g_hEvent); return 0;
}
在这个例子中,我们创建了一个全局的Event对象g_hEvent,这个对象用于同步多个线程。线程执行需要同步的代码前,首先调用WaitForSingleObject函数等待事件对象被设置,即等待允许执行的信号。主线程在创建所有子线程之后,调用SetEvent函数设置事件对象,多个线程才被允许执行。这样就能确保多个线程按照我们的要求同步执行,达到线程同步的目的。
该文章会更新,欢迎大家批评指正。
推荐一个零声学院免费公开课程,个人觉得老师讲得不错,
分享给大家:[Linux,Nginx,ZeroMQ,MySQL,Redis,
fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker,
TCP/IP,协程,DPDK等技术内容,点击立即学习:
服务器课程:C++服务器