CreateEvent SetEvent WaitForSingleObjec

article/2025/10/15 9:32:20

在自动重置事件对象中,当WaitSingleObject/WaitForMultipleObjects接收到SetEvent发送过来的信号后则返回WAIT_OBJECT_0,此时操作系统(待定)自动重置等待的事件对象(即自动将其设置为无信号状态。无论何时通过SetEvent发送过来的信号,只要未被接收到均不会被自动重置。但在未被接收之前可以调用ResetEvent手动重置等待的事件对象,此时等待的事件对象为无信号状态)。在手动重置事件对象中,当WaitSingleObject/WaitForMultipleObjects接收到SetEvent发送过来的信号后则返回WAIT_OBJECT_0,此时需要调用ResetEvent手动重置等待的事件对象(即手动将其设置为无信号状态)。

[cpp]  view plain copy
  1. #include <windows.h>  
  2. #include <iostream>  
  3. using namespace std;  
  4.   
  5. DWORD WINAPI ThreadProc(LPVOID lpParam);  
  6. DWORD WINAPI ThreadProc2(LPVOID lpParam);  
  7.   
  8. DWORD g_dwThreadID;  
  9. DWORD g_dwThreadID2;  
  10.   
  11. UINT g_nTickets = 300;  
  12. HANDLE g_hEvent = NULL;  
  13.   
  14. int main(int argc, char* argv[])  
  15. {  
  16.  cout << "Main thread is running." << endl;  
  17.    
  18.  HANDLE hHandle = CreateThread(NULL, 0, ThreadProc, NULL, 0, &g_dwThreadID);  
  19.  HANDLE hHandle2 = CreateThread(NULL, 0, ThreadProc2, NULL, 0, &g_dwThreadID2);  
  20.  CloseHandle(hHandle);   
  21.  CloseHandle(hHandle2);  
  22.   
  23.  g_hEvent = CreateEvent(NULL, FALSE,  TRUE, NULL);  
  24.   
  25.  Sleep(4000);  
  26.  system("pause");  
  27.  return 0;  
  28. }  
  29.   
  30. DWORD WINAPI ThreadProc(LPVOID lpParam)  
  31. {   
  32.  // cout << "No." << g_dwThreadID << " thread is running." << endl;  
  33.  while (TRUE)  
  34.  {  
  35.   WaitForSingleObject(g_hEvent, INFINITE);  
  36.   if (g_nTickets > 0)  
  37.   {  
  38.    Sleep(1);  
  39.    cout << "No.1-" << g_dwThreadID << " sell ticket : " << g_nTickets << endl;  
  40.    g_nTickets--;  
  41.    SetEvent(g_hEvent);   
  42.   }  
  43.   else  
  44.   {  
  45.    break;  
  46.   }  
  47.  }  
  48.  return 0;  
  49. }  
  50.   
  51. DWORD WINAPI ThreadProc2(LPVOID lpParam)  
  52. {  
  53.  // cout << "No." << g_dwThreadID2 << " thread is running." << endl;  
  54.  while (TRUE)  
  55.  {  
  56.   WaitForSingleObject(g_hEvent, INFINITE);  
  57.   if (g_nTickets > 0)  
  58.   {  
  59.    Sleep(1);  
  60.    cout << "No.2-" << g_dwThreadID2 << " sell ticket : " << g_nTickets << endl;  
  61.    g_nTickets--;  
  62.    SetEvent(g_hEvent);  
  63.   }  
  64.   else  
  65.   {  
  66.    break;  
  67.   }  
  68.  }  
  69.  return 0;  
  70. }  

说明:建议先下载本文配套工程,其中

EventMain工程、EventSubA工程,EventSubB工程分别用于演示进程间通信的主进程和两个子进程

下载地址:http://download.csdn.net/detail/danny_share/7720043

 注意:

1.不要F5直接运行

2.编译生成debug目录或者release目录以后,如果要实验第二部分生命周期的时候,请手动打开EventMain.exe和EventSubA.exe;如果要实验第三部分的时候,请只手动打开EventMain.exe,另外两个exe文件不要手动打开


一.  概念

事件实际属于线程同步对象的范畴,主要通过事件状态的改变实现发送通知。

事件属于windows内核对象,其标识符为一个HANDLE句柄,且因为每个进程至少含有一个主线程,因此可用于多进程环境。

 

二.生命周期

1.出生

通过CreateEvent或者CreateEventEx创建一个事件对象

CreateEvent创建方式

[cpp]  view plain copy
  1. HANDLE WINAPI CreateEvent(  
  2.  _In_opt_  LPSECURITY_ATTRIBUTES lpEventAttributes,  
  3.  _In_      BOOL bManualReset,  
  4.  _In_      BOOL bInitialState,//TRUE表示创建时已是激活状态  
  5.  _In_opt_  LPCTSTR lpName  
  6. );  

CreateEventEx创建方式

[cpp]  view plain copy
  1. HANDLE WINAPI CreateEventEx(  
  2.   _In_opt_  LPSECURITY_ATTRIBUTES lpEventAttributes,  
  3.   _In_opt_  LPCTSTR lpName,  
  4.   _In_      DWORD dwFlags,  //CREATE_EVENT_INITIAL_SET或者CREATE_EVENT_MANUAL_RESET  
  5.   _In_      DWORD dwDesiredAccess  
  6. );  

(1)       lpEventAttributes表示创建时的安全属性

vista系统和win7系统相比于xp,安全性较高,因此,对于大部分将此值设为NULL的应用,可能会发生在xp下运行正常,而在vista和win7异常的情况。

(2)CreateEvent的bManualReset相当于_CreateEventEx的In_DWORD dwFlags

     如果为manual,每次事件激活以后,需调用ResetEvent设置非激活

     若为auto,则时间处于激活状态后,只要有一个wait成功,就会自动处于非激活状态

(3)CreateEventEx比CreateEvent少了一个初始状态参数bInitialState,通过以下实验可以证明,CreateEventEx创建的事件初始状态是非激活的

参见主工程EventMain中界面上“Test CreateEventEx InitState”按钮上效果

[cpp]  view plain copy
  1. HANDLEtestHandle=::CreateEventEx(NULL,"TestCreateEventEx",CREATE_EVENT_MANUAL_RESET,EVENT_ALL_ACCESS);  
  2. DWORDresult=::WaitForSingleObject(testHandle,1000);  



(4)      CreateEventEx比CreateEvent多了一个dwDesiredAccess,用来标识访问属性

或者是通过OpenEvent打开一个已经存在的事件

[cpp]  view plain copy
  1. HANDLE WINAPI OpenEvent(  
  2.  _In_  DWORD dwDesiredAccess,  
  3.  _In_  BOOL bInheritHandle,  
  4.  _In_  LPCTSTR lpName  //CreateEvent中指定的名称  
  5. );  

2.成长

较为简单

(1)SetEvent激活事件状态

(2)ResetEvent重置事件状态

(3)PaulseEvent,我觉得我们可以忽略它


3.死亡

事件属于内核对象,Windows平台对于内核对象的管理采用“引用计数”这个方式

(1)      通过CreateEvent创建完成后该事件内核对象的引用计数为1

(2)      以后每OpenEvent一次,该事件对象的引用计数就加1

(3)      每CloseHandle一次,该事件对象的引用计数就减1

(4)      当内核对象的引用计数为0时,操作系统就回收该内核资源

为此我们准备了两个进程(详见工程下载),一个进程EventMain承担上述进程M的责任,另一个进程EventSubA承担进程A的责任,下面我们来做些实验验证以上说法,两个进程界面截图如下:


(1)      M创建事件,M关闭事件,M再打开事件,失败很好理解

(2)      M创建事件后,使M崩溃,A打开该事件失败.说明进程结束以后,系统会自动将该进程拥有的引用计数减去

(3)      M创建事件后,A打开该事件,M崩溃,A再打开成功A打开事件后,该事件引用计数变为2,M崩溃后计数为1,故系统不回收

 

三.API汇总

第二部分其实已经包含了所有的API

ID

API

功能

1

CreateEvent

创建事件对象

2

CreateEventEx

 

3

OpenEvent

打开事件对象

4

SetEvent

置为激活状态

5

ResetEvent

置为非激活状态

6

PaulseEvent

产生事件脉冲

7

CloseHandle

关闭windows内核对象都用这个函数

 

四.使用事件实现进程通信

1.设计

(1)两个子进程在后台等待事件发生

(2)主进程激活事件,相当于发出命令

(3)子进程收到命令,激活响应事件,相当于响应

(4)由于事件本身不具备传输数据的能力,所以这里只能传输命令

 

2.实现

(1)主进程创建八个事件

Work1和Work2用来区分不同的命令

前缀A和B后来区分发给哪个进程,以及响应是哪个进程发来的

从这里我们也可以发现,由于事件本身无法传输标志位,导致需要创建很多事件来区分不同的命令或响应


AWork1,主进程向子进程A发送AWork1命令的事件

AWork2,主进程向子进程A发送AWork2命令的事件

BWork1,主进程向子进程B发送BWork1命令的事件

BWork2,主进程向子进程B发送BWork2命令的事件

AResponse1,子进程A向主进程响应AResponse1的事件

AResponse2,子进程A向主进程响应AWork2命令的事件

BResponse1,子进程B向主进程响应Work1命令的事件

BResponse2,子进程B向主进程响应Work2命令的事件


之后Set相关命令事件 



(2)然后A子进程wait到主进程发来的命令,并将Set响应事件

(3)主进程wait到响应事件

 

 

贴上主进程的关键代码

[cpp]  view plain copy
  1. voidCEventMainDlg::OnBnClickedButton9()  
  2. {  
  3.     if(!isOpenSubProcess)  
  4.     {  
  5.        this->openSubProcess();  
  6.        Sleep(1000);  
  7.     }  
  8.    
  9.     if(this->m_commandCTL.GetCurSel()==0)  
  10.     {  
  11.        if(this->m_processCTL.GetCurSel()==0)  
  12.        {  
  13.            ::SetEvent(commandHandleA[0]);  
  14.            if(WAIT_OBJECT_0==::WaitForSingleObject(responseHandleA[0],2000))  
  15.            {  
  16.               MessageBox("receive A response Work1 success","Info",MB_OK);  
  17.            }  
  18.            else  
  19.            {  
  20.               MessageBox("receive A response Work1 failed","Info",MB_OK);  
  21.            }  
  22.        }  
  23.        else  
  24.        {  
  25.            ::SetEvent(commandHandleB[0]);  
  26.            if(WAIT_OBJECT_0==::WaitForSingleObject(responseHandleB[0],2000))  
  27.            {  
  28.               MessageBox("receive B response Work1 success","Info",MB_OK);  
  29.            }  
  30.            else  
  31.            {  
  32.               MessageBox("receive B response Work1 failed","Info",MB_OK);  
  33.            }  
  34.        }  
  35.     }  
  36.     else  
  37.     {  
  38.        if(this->m_processCTL.GetCurSel()==0)  
  39.        {  
  40.            ::SetEvent(commandHandleA[1]);  
  41.            if(WAIT_OBJECT_0==::WaitForSingleObject(responseHandleA[1],2000))  
  42.            {  
  43.               MessageBox("receive A response Work2 success","Info",MB_OK);  
  44.            }  
  45.            else  
  46.            {  
  47.               MessageBox("receive A response Work2 failed","Info",MB_OK);  
  48.            }  
  49.        }  
  50.        else  
  51.        {  
  52.            ::SetEvent(commandHandleB[1]);  
  53.            if(WAIT_OBJECT_0==::WaitForSingleObject(responseHandleB[1],2000))  
  54.            {  
  55.               MessageBox("receive B response Work2 success","Info",MB_OK);  
  56.            }  
  57.            else  
  58.            {  
  59.               MessageBox("receive B response Work2 failed","Info",MB_OK);  
  60.            }  
  61.        }  
  62.     }  
  63.    
  64.    
  65.     ::ResetEvent(commandHandleA[0]);  
  66.     ::ResetEvent(commandHandleA[1]);  
  67.     ::ResetEvent(commandHandleB[0]);  
  68.     ::ResetEvent(commandHandleB[1]);  
  69.    
  70. }  

贴上子进程A的关键代码

[cpp]  view plain copy
  1. voidthreadFunA(void* Param)  
  2. {  
  3.     HANDLEcommandHandle[2]={NULL,NULL};  
  4.     commandHandle[0]=::OpenEvent(EVENT_ALL_ACCESS,TRUE,"AWork1");  
  5.     commandHandle[1]=::OpenEvent(EVENT_ALL_ACCESS,TRUE,"AWork2");  
  6.     HANDLEresponseHandle1=::OpenEvent(EVENT_ALL_ACCESS,TRUE,"AResponse1");  
  7.     HANDLEresponseHandle2=::OpenEvent(EVENT_ALL_ACCESS,TRUE,"AResponse2");  
  8.     while(true)  
  9.     {  
  10.        DWORDresult=::WaitForMultipleObjects(2,commandHandle,FALSE,INFINITE);  
  11.        if( WAIT_OBJECT_0 == result )  
  12.        {  
  13.            ::SetEvent(responseHandle1);  
  14.            ::ResetEvent(commandHandle[0]);  
  15.        }  
  16.        else  
  17.        {  
  18.            if(result==(WAIT_OBJECT_0 +1))  
  19.            {  
  20.               ::SetEvent(responseHandle2);  
  21.               ::ResetEvent(commandHandle[1]);  
  22.            }  
  23.        }  
  24.     }  
  25. }  

五.总结

1.事件本身和自定义消息在跨进程环境中都不太适合传输数据,只适合传输命令,

  但事件是毫无传数据的能力,自定义消息至少还能传传简单数据。

2.和WM_COPYDATA以及剪贴板相比,事件可以实现同时向两个后台进程发送命令。

    虽然这里我们区分了,但是实际上只要连个后台进程同时wait同一个事件,

   当主进程Set该事件时,两个后台进程可同时接收到。

3.事件更适合用来互斥和同步,当要传输数据的时候,应该配合其他机制来实现

 



http://chatgpt.dhexx.cn/article/cg3B3PgH.shtml

相关文章

线程中CreateEvent和SetEvent及WaitForSingleObject的用法

首先介绍CreateEvent是创建windows事件的意思&#xff0c;作用主要用在判断线程退出&#xff0c;线程锁定方面. CreateEvent 函功能描述&#xff1a;创建或打开一个命名的或无名的事件对象. EVENT有两种状态&#xff1a;发信号&#xff0c;不发信号。 SetEvent/ResetEvent…

wireshark找不到接口?你的NPF没启动

使用wireshark时会遇到找不到接口的问题&#xff0c;这是因为电脑的NPF没有启动。以管理员身份运行cmd,输入net start npf即可。不过&#xff0c;电脑重启后&#xff0c;它又关闭了。

wireshark抓包报错The capture session could not be initiated on interface '\Device\NPF_Loopback'

wireshark抓包报错 The capture session could not be initiated on interface ‘\Device\NPF_Loopback’ (Error opening adapter: The system cannot find the path specified. (3)). 解决方法 以管理员身份运行cmd&#xff0c;输入net start npcap 重新打开wireshark即可…

The NPF or NPCAP service is not installed, please install Winpcap or Npcap aand reboot的解决方法

安装好GNS启动后&#xff0c;我遇到了GNS3没有加载的错误&#xff0c;并且发出错误声明“未安装NPF或NPCAP服务&#xff0c;请安装Winpcap或Npcap并重启。” 确认已经安装了winpcap&#xff0c;怎么还会报错呢&#xff1f;&#xff1f;后来发现是没有勾选自启动winpcap软件导致…

wireshark提示未启动npf服务The NPF driver isn’t running You may have trouble capturing or listing interfaces

提示未启动npf服务的解决办法 检查你的电脑有没有安装WinPcap&#xff0c;如果没有安装就安装一下以管理员身份运行cmd.exe&#xff0c;执行命令&#xff1a;sc config npf start auto&#xff0c;重启wireshark如果还提示未启动npf服务就执行这个命令&#xff1a;net start n…

解决启动Wireshark时遇到的“The NPF driver isn't running...”

最近在使用wireshark抓包软件的时候遇到了这个问题&#xff0c;在启动wireshark的时候&#xff0c;会弹出一个对话框&#xff1a; 上网搜索了一下&#xff0c;结合自己的想法&#xff0c;得到如下两个解决方法&#xff1a; 一、图形界面操作 1、右击计算机&#xff0c;“管理”…

wireshark/The NPF driver isn’t running./Unable to load WinPcap (wpcap.dll)

很久没使用wireshark后重新打开就出现警告&#xff1a; The NPF driver isn’t running. You may have trouble capturing or listing interfaces. 点击菜单栏caption&#xff0c;准备启动的时候&#xff0c;又显示警告框&#xff0c;直接不给操作&#xff1a; Unable to load …

使用Wireshark抓包软件提示The NPF driver isn’t running解决办法

Wireshark一个强大的数据抓包分析工具&#xff0c;在Win7 64位系统上第一次使用时&#xff0c;可能会出现意外的情况。 The NPF driver isn’t running. 这个情况可能是因为没有安装Winpcap驱动或者安装Winpcap时没有选中开机自动启动winpcap选项。 解决方法&#xff1a; 1. 没…

【西门子】S7-PLCSIM Advance_V2/V3, Error Code: -30,LicenseNotFound /NetGroup Packet Filter Driver (NPF)

最近公司需要测试视觉程序与西门子S7-1500通讯&#xff0c;下载了下西门子的编程程序进行通讯测试&#xff0c;本来想着安装个程序很简单的事&#xff0c;谁知道在使用S7-PLCSIM Advance_V3仿真通讯时遇到各种问题&#xff0c;鉴于自己踩坑太多&#xff0c;特此分享自己的完美解…

wireshark找不到捕获接口问题和net start npf 服务器名无效、拒绝访问的解决办法

win10系统 解决方法&#xff1a; 1、去官网下载用于网络封包抓取的工具 winpcap 链接&#xff1a;https://www.winpcap.org/install/bin/WinPcap_4_1_3.exe 2、用管理员身份运行命令提示符 3、输入net start npf 启动服务 可以看到有捕获接口了

Wireshark学习篇(1)---NPF driver is not running error

在互联网这个行业里&#xff0c;怎能不熟悉几款抓包工具呢。将Wireshark作为首选学习工具&#xff0c;此工具功能比较强大&#xff0c;是基于网卡级别进行的抓包。在电脑上安装了 Wireshark后&#xff0c;首次登录的时候&#xff0c;会有"NPF driver is not running"…

[安装wireshark时,报“Error opening file for writing npf.sys”]

问题来源&#xff1a; 最近拷贝了别人一个win10的虚拟机&#xff0c;用wireshark抓帧时&#xff0c;一直找不到wifi的网卡&#xff0c;导致抓不了帧。 查找问题&#xff1a; 在win10下输入命令&#xff1a; C:\Program Files\Wireshark>tshark -DThe NPF driver isnt run…

解决打开S7-PLCSIM Advanced V3.0报错NetGroup Packet Filter Driver (NPF)

在安装S7-PLCSIM Advanced V3.打开仿真的时候网卡报错。以管理员模式打开cmd&#xff0c;输入net start npf开启npf的时候显示服务名无效&#xff0c;原因是没有安装winpcap&#xff0c;在安装winpcap后再以管理员模式运行cmd&#xff0c;输入net start npf后成功打开npf。本文…

win7环境下 net start npf服务名无效的解决方法。

一、这个问题的起因是wireshark找不到本地接口引起的&#xff0c;在网上找到的解决方法是&#xff1a;把 新版的winpcap删除再重装个老版的。(再次证明软件还是用老的好&#xff0c;新的有BUG)。 操作方法如下&#xff1a;找到对应的文件&#xff0c;并把扩展名修改即可。 C:\…

net start npf启用失败问题解决 net start npf 发生系统错误5、net start npf 服务名无效

问题1&#xff1a;net start npf 服务名无效 Wireshark找不到网卡 输入net start npf 服务名无效 解决办法1&#xff1a;下载winpcap 地址&#xff1a;https://www.winpcap.org/install/bin/WinPcap_4_1_3.exe 安装完winpcap&#xff0c;在cmd&#xff08;要以管理员模式运行…

[转]NPF驱动核心指南(含与NDIS区别)

这是WinPcap的NPF驱动核心指南原文的翻译&#xff0c;英语水平有限&#xff0c;翻译得可能不是很准确。 这个章节说明网络组包过滤&#xff08;NPF&#xff09;组件&#xff0d;WinPcap的核心部分。一般用户可能只对WinPcap的使用感兴趣&#xff0c;但不一定想了解它的组件结构…

贝叶斯文本分类

朴素贝叶斯分类 贝叶斯分类 贝叶斯分类是一类分类算法的总称&#xff0c;这类算法均以贝叶斯定理为基础&#xff0c;故统称为贝叶斯分类而朴素朴素贝叶斯分类是贝叶斯分类中最简单&#xff0c;也是常见的一种分类方法分类问题综述 对于分类问题&#xff0c;其实谁都不会陌生&am…

贝叶斯分类numpy实现

概述 贝叶斯属于生成模型的一种&#xff0c;其实现很简单&#xff0c;就是应用贝叶斯公式。这是一种指定先验分布&#xff0c;求后验的方法。 概率论课本里著名的贝叶斯公式如下 p(ci)是i类在数据集的占比&#xff0c;&#xff08;数一下就可&#xff0c;易&#xff09; p(x|…

python编程实现贝叶斯分类

贝叶斯的思想比较简单&#xff0c;网上阐述也很详细&#xff0c;这里就不赘述了。 这里只是简单的说一下编程的思路 首先明确我们要实验的内容&#xff0c;实现贝叶斯分类&#xff0c;那么要想编程实现&#xff0c;你必须对贝叶斯分类有足够的了解。而贝叶斯分类的过程并不难&a…

机器学习-贝叶斯分类实验

机器学习-贝叶斯分类 1. 中文文本分类介绍2. 文本分类的一般步骤&#xff1a;3. 具体操作4. 实验步骤5. 实验完整代码python 1. 中文文本分类介绍 文本挖掘是指从大量的文本数据中抽取事先未知的、可理解的、最终可用的知识的过程&#xff0c;同时运用这些知识更好的组织信息以…