首页    技术博客    PHP教程    数据库技术    前端开发   HTML5    Nginx    php论坛
新用户注册 | 会员登录
加入会员，解锁专属内容
取消
热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

基于visualc++之windows核心编程代码分析（14）使用Event同步线程

作者：bw32dts | 来源：互联网 | 2023-09-24 07:44
我们进行Windows编程编写多线程程序的时候经常需要用到线程同步，我们来实现用Event同步线程。请见代码注释与实例讲解。[cpp]viewplaincopy*头文件*#incl

我们进行Windows编程编写多线程程序的时候经常需要用到线程同步，我们来实现用Event同步线程。

请见代码注释与实例讲解。

 

[cpp] view plain copy
  1. /* 头文件　*/  
  2. #include   
  3. #include   
  4. /* 常量定义　*/  
  5. #define NUMTHREADS  3   
  6. #define BUFFER_SIZE 16  
  7. #define FOR_TIMES   5  
  8. /* 全局变量　*/  
  9. HANDLE hWriteEvent[NUMTHREADS];     // 写Event 表示写操作是否完成  
  10. HANDLE hReadEvents[NUMTHREADS]; // 读Event 表示读操作是否完成  
  11. BYTE lpSharedBuffer[16] = {0};  // 共享内存  
  12. /* 函数声明　*/  
  13. void MultiEvents(void);  
  14. VOID WriteToBuffer(VOID);  
  15. DWORD WINAPI ThreadFunction(LPVOID lpParam);  
  16.   
  17. /************************************* 
  18. * int main(void) 
  19. * 功能    演示 
  20. * 
  21. * 参数    未使用 
  22. **************************************/  
  23. int main()  
  24. {  
  25.     MultiEvents();  
  26. }  
  27.   
  28. /************************************* 
  29. * void UseEvents(void)  
  30. * 功能    演示Event的使用方法 
  31. * 
  32. * 参数    未使用 
  33. **************************************/  
  34. void MultiEvents(void)   
  35. {  
  36.     HANDLE hThread;   
  37.     DWORD i;   
  38.     // 创建多个线程，读共享内存，主线程写共享内存。  
  39.     // 每个线程都有对应的读写同步事件  
  40.     for(i = 0; i < NUMTHREADS; i++)   
  41.     {  
  42.         // 每个线程都有一个Event表示写入操作完成  
  43.         hWriteEvent[i] = CreateEvent(   
  44.             NULL,           // 默认安全属性  
  45.             FALSE,          // 自动重置  
  46.             FALSE,          // 初始为未置位的  
  47.             NULL            // 未命名  
  48.             );  
  49.         // 判断是否创建成功  
  50.         if (hWriteEvent[i] == NULL)   
  51.         {   
  52.             printf("CreateEvent failed (%d)\n", GetLastError());  
  53.             return;  
  54.         }  
  55.         // 每个读线程有一个Event表示读操作已经完成  
  56.         hReadEvents[i] = CreateEvent(   
  57.             NULL,     // 默认安全属性  
  58.             FALSE,    // 自动重置  
  59.             FALSE,    // 初始化为未置位的  
  60.             NULL);    // 未命名  
  61.         if (hReadEvents[i] == NULL)   
  62.         {  
  63.             printf("CreateEvent failed (%d)\n", GetLastError());  
  64.             return;  
  65.         }  
  66.         // 创建线程  
  67.         hThread = CreateThread(NULL, 0,   
  68.             ThreadFunction,   
  69.             (LPVOID)i,  // Event对象句柄作为  
  70.             0, NULL);   
  71.         if (hThread == NULL)   
  72.         {  
  73.             printf("CreateThread failed (%d)\n", GetLastError());  
  74.             return;  
  75.         }  
  76.     }  
  77.     WriteToBuffer();  
  78. }  
  79.   
  80. /************************************* 
  81. * VOID WriteToBuffer(INT iContent)  
  82. * 功能    由主线程调用，向共享内存中写入数据 
  83. *       等待所有读线程读完后函数返回 
  84. * 
  85. * 参数    未使用 
  86. **************************************/  
  87. VOID WriteToBuffer(VOID)   
  88. {  
  89.     DWORD dwWaitResult, j,i;  
  90.     // 完成 FOR_TIMES 次读写  
  91.     for (j = 0; j < FOR_TIMES; j++)  
  92.     {         
  93.         Sleep(rand()%100);  // 写入需要的时间随机  
  94.         // 写入共享内存  
  95.         wsprintf(lpSharedBuffer,"shared %d",j);  
  96.         // 将线程对应的写Event置为“标志的”，表示写操作完成，  
  97.         // 其他线程可以开始读  
  98.         for(i=0; i
  99.         {  
  100.             if (! SetEvent(hWriteEvent[i]) )   
  101.             {   
  102.                 printf("SetEvent failed (%d)\n", GetLastError());  
  103.                 return;  
  104.             }  
  105.         }  
  106.         // 等待所有的线程读完，开始下次写入  
  107.         dwWaitResult = WaitForMultipleObjects(   
  108.             NUMTHREADS,   // Event句柄的个数  
  109.             hReadEvents,  // Event句柄数组  
  110.             TRUE,         // 等到所有的Event都被标志  
  111.             INFINITE);    // 无限等待  
  112.         // 判断等待结果  
  113.         if (dwWaitResult != WAIT_OBJECT_0)   
  114.         {  
  115.             printf("Wait error: %d\n", GetLastError());   
  116.             ExitProcess(0);   
  117.         }  
  118.     }  
  119. }  
  120.   
  121. /************************************* 
  122. * DWORD WINAPI ThreadFunction(LPVOID lpParam) 
  123. * 功能    线程函数，读共享内存 
  124. * 
  125. * 参数    LPVOID lpParamt 实际为指向Event句柄的指针 
  126. **************************************/  
  127. DWORD WINAPI ThreadFunction(LPVOID lpParam)   
  128. {  
  129.     DWORD dwWaitResult;  
  130.     BYTE lpRead[16];  
  131.     DWORD j = 0;  
  132.     DWORD dwThreadIndex  = (DWORD)lpParam;  
  133.     // 完成 FOR_TIMES 次读写  
  134.     for(; j
  135.     {  
  136.         // 等待写事件置位，表示数据已经写入  
  137.         dwWaitResult = WaitForSingleObject(   
  138.             hWriteEvent[dwThreadIndex], // Event 句柄  
  139.             INFINITE);                  // 无限等待  
  140.         switch (dwWaitResult)   
  141.         {  
  142.         case WAIT_OBJECT_0:  
  143.             Sleep(rand()%10);           // 模拟数据处理所需的时间随机  
  144.             CopyMemory(lpRead,lpSharedBuffer,16);  
  145.             break;   
  146.             // 发生错误  
  147.         default:   
  148.             printf("Wait error: %d\n", GetLastError());   
  149.             ExitThread(0);   
  150.         }  
  151.         // 将读Event置位，表示读操作完成  
  152.         if (! SetEvent(hReadEvents[dwThreadIndex]) )   
  153.         {   
  154.             printf("SetEvent failed (%d)\n", GetLastError());  
  155.             return 0;  
  156.         }  
  157.         //打印读到的内容  
  158.         printf("线程 %u\t第 %d 次读，内容：%s\n",  
  159.             dwThreadIndex,j,(LPSTR)lpRead);  
  160.     }  
  161.     return 1;  
  162. }  
推荐阅读
  • list

    MFC动态创建窗口的实现方法及注意事项

    本文介绍了在MFC下利用C++和MFC的特性动态创建窗口的方法，包括继承现有的MFC类并加以改造、插入工具栏和状态栏对象的声明等。同时还提到了窗口销毁的处理方法。本文详细介绍了实现方法并给出了相关注意事项。 ... [详细]
  • uri

    全面介绍Windows内存管理机制及C++内存分配实例（四）：内存映射文件

    全面介绍Windows内存管理机制及C++内存分配实例（四）：内存映射文件
    本文旨在全面介绍Windows内存管理机制及C++内存分配实例中的内存映射文件。通过对内存映射文件的使用场合和与虚拟内存的区别进行解析，帮助读者更好地理解操作系统的内存管理机制。同时，本文还提供了相关章节的链接，方便读者深入学习Windows内存管理及C++内存分配实例的其他内容。 ... [详细]
  • object

    OC学习笔记之@property和@synthesize

    本文介绍了OC学习笔记中的@property和@synthesize，包括属性的定义和合成的使用方法。通过示例代码详细讲解了@property和@synthesize的作用和用法。 ... [详细]
  • object

    Java中vector的使用详解

    本文详细介绍了Java中vector的使用方法和相关知识，包括vector类的功能、构造方法和使用注意事项。通过使用vector类，可以方便地实现动态数组的功能，并且可以随意插入不同类型的对象，进行查找、插入和删除操作。这篇文章对于需要频繁进行查找、插入和删除操作的情况下，使用vector类是一个很好的选择。 ... [详细]
  • web

    如何在Windows环境下配置php+apache环境

    本文介绍了在Windows环境下如何配置php+apache环境，包括下载php7和apache2.4、安装vc2015运行时环境、启动php7和apache2.4等步骤。希望对需要搭建php7环境的读者有一定的参考价值。摘要长度为169字。 ... [详细]
  • list

    Day2列表、字典、集合操作详解

    Day2列表、字典、集合操作详解
    本文详细介绍了列表、字典、集合的操作方法，包括定义列表、访问列表元素、字符串操作、字典操作、集合操作、文件操作、字符编码与转码等内容。内容详实，适合初学者参考。 ... [详细]
  • list

    操作系统的定义和功能

    本文介绍了操作系统的定义和功能，包括操作系统的本质、用户界面以及系统调用的分类。同时还介绍了进程和线程的区别，包括进程和线程的定义和作用。 ... [详细]
  • int

    使用eclipse创建一个Java项目的步骤

    使用eclipse创建一个Java项目的步骤
    本文介绍了使用eclipse创建一个Java项目的步骤，包括启动eclipse、选择New Project命令、在对话框中输入项目名称等。同时还介绍了Java Settings对话框中的一些选项，以及如何修改Java程序的输出目录。 ... [详细]
  • int

    VSCode快速查看函数定义和代码追踪方法详解

    VSCode快速查看函数定义和代码追踪方法详解
    本文详细介绍了在VSCode中快速查看函数定义和代码追踪的方法，包括跳转到定义位置的三种方式和返回跳转前的位置的快捷键。同时，还介绍了代码追踪插件的使用以及对符号跳转的不足之处。文章指出，直接跳转到定义和实现的位置对于程序员来说非常重要，但需要语言本身的支持。以TypeScript为例，按下F12即可跳转到函数的定义处。 ... [详细]
  • int

    linux进阶50——无锁CAS

    linux进阶50——无锁CAS
    1.概念比较并交换(compareandswap，CAS)，是原⼦操作的⼀种，可⽤于在多线程编程中实现不被打断的数据交换操作࿰ ... [详细]
  • python

    通过Anaconda安装tensorflow，并安装运行spyder编译器的完整教程

    通过Anaconda安装tensorflow，并安装运行spyder编译器的完整教程
    本文提供了一个完整的教程，介绍了如何通过Anaconda安装tensorflow，并安装运行spyder编译器。文章详细介绍了安装Anaconda、创建tensorflow环境、安装GPU版本tensorflow、安装和运行Spyder编译器以及安装OpenCV等步骤。该教程适用于Windows 8操作系统，并提供了相关的网址供参考。通过本教程，读者可以轻松地安装和配置tensorflow环境，以及运行spyder编译器进行开发。 ... [详细]
  • shell

    Python脚本编写创建输出数据库并添加模型和场数据的方法

    Python脚本编写创建输出数据库并添加模型和场数据的方法
    本文介绍了使用Python脚本编写创建输出数据库并添加模型数据和场数据的方法。首先导入相应模块，然后创建输出数据库并添加材料属性、截面、部件实例、分析步和帧、节点和单元等对象。接着向输出数据库中添加场数据和历程数据，本例中只添加了节点位移。最后保存数据库文件并关闭文件。文章还提供了部分代码和Abaqus操作步骤。另外，作者还建立了关于Abaqus的学习交流群，欢迎加入并提问。 ... [详细]
  • object

    ejava,刘聪dejava

    ejava,刘聪dejava
    本文目录一览：1、什么是Java？2、java ... [详细]
  • int

    七月在线爬虫班学习笔记（七）——高级内容-并发编程

    第七课主要内容：多进程多线程FIFO,LIFO,优先队列线程局部变量进程与线程的选择线程池异步IO概念及twisted案例股票数据抓取 ... [详细]
  • object

    Simple Tips on C++(对于C++的一些建议)

    Introduction（简介）Forbeingapowerfulobject-orientedprogramminglanguage,Cisuseda ... [详细]
author-avatar
bw32dts
这个家伙很懒，什么也没留下！
Tags | 热门标签
RankList | 热门文章
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有