AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Linux平台用C++实现事件对象，同步线程

2017-08-16 1342
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 前文在Win32平台上用C++实现了事件对象Event，对线程进行同步，以达到期望目的。这次在Linux平台上实现与之类似的事件对象。与其相关的一组API包括：pthread_mutex_init，pthread_cond_init，pthread_mutex_lock，pthread_cond_wait，pthread_mutex_unlock，pthread_cond_broadcast，pthread_cond_timedwait，pthread_cond_destroy，pthread_mutex_destroy。

前文在Win32平台上用C++实现了事件对象Event，对线程进行同步，以达到期望目的。这次在Linux平台上实现与之类似的事件对象。与其相关的一组API包括：pthread_mutex_init，pthread_cond_init，pthread_mutex_lock，pthread_cond_wait，pthread_mutex_unlock，pthread_cond_broadcast，pthread_cond_timedwait，pthread_cond_destroy，pthread_mutex_destroy。这些API的说明可以在这里找到：http://www.9linux.com/。下边，是封装的事件对象类，以及测试代码。使用VS2005编辑，在虚拟机 Fedora 13中编译，测试通过。

MyEvent.h

[cpp]  view plain  copy
 
  1. #ifndef My_Event_Header  
  2. #define My_Event_Header  
  3.   
  4. #include <iostream>  
  5. #include <pthread.h>  
  6. #include <errno.h>  
  7.   
  8. using namespace std;  
  9.   
  10. //---------------------------------------------------------------  
  11.   
  12. class CEventImpl  
  13. {  
  14. protected:  
  15.       
  16.     /* 
  17.      动态方式初始化互斥锁,初始化状态变量m_cond 
  18.     `bAutoReset  true   人工重置 
  19.                  false  自动重置 
  20.     */  
  21.     CEventImpl(bool manualReset);         
  22.       
  23.     /* 
  24.      注销互斥锁,注销状态变量m_cond 
  25.     */  
  26.     ~CEventImpl();  
  27.   
  28.     /* 
  29.      将当前事件对象设置为有信号状态 
  30.      若自动重置，则等待该事件对象的所有线程只有一个可被调度 
  31.      若人工重置，则等待该事件对象的所有线程变为可被调度 
  32.     */  
  33.     void SetImpl();  
  34.   
  35.     /* 
  36.      以当前事件对象，阻塞线程，将其永远挂起 
  37.      直到事件对象被设置为有信号状态 
  38.     */  
  39.     bool WaitImpl();  
  40.   
  41.     /* 
  42.      以当前事件对象，阻塞线程，将其挂起指定时间间隔 
  43.      之后线程自动恢复可调度 
  44.     */  
  45.     bool WaitImpl(long milliseconds);  
  46.   
  47.     /* 
  48.      将当前事件对象设置为无信号状态 
  49.     */  
  50.     void ResetImpl();  
  51.   
  52. private:  
  53.     bool            m_manual;  
  54.     volatile bool   m_state;  
  55.     pthread_mutex_t m_mutex;  
  56.     pthread_cond_t  m_cond;  
  57. };  
  58.   
  59. inline void CEventImpl::SetImpl()  
  60. {  
  61.     if (pthread_mutex_lock(&m_mutex))     
  62.         cout<<"cannot signal event (lock)"<<endl;  
  63.   
  64.     //设置状态变量为true，对应有信号  
  65.     m_state = true;  
  66.   
  67.     //cout<<"CEventImpl::SetImpl m_state = "<<m_state<<endl;  
  68.   
  69.     //重新激活所有在等待m_cond变量的线程  
  70.     if (pthread_cond_broadcast(&m_cond))  
  71.     {  
  72.         pthread_mutex_unlock(&m_mutex);  
  73.         cout<<"cannot signal event"<<endl;  
  74.     }  
  75.     pthread_mutex_unlock(&m_mutex);  
  76. }  
  77.   
  78. inline void CEventImpl::ResetImpl()  
  79. {  
  80.     if (pthread_mutex_lock(&m_mutex))     
  81.         cout<<"cannot reset event"<<endl;  
  82.   
  83.     //设置状态变量为false，对应无信号  
  84.     m_state = false;  
  85.   
  86.     //cout<<"CEventImpl::ResetImpl m_state = "<<m_state<<endl;  
  87.   
  88.     pthread_mutex_unlock(&m_mutex);  
  89. }  
  90.   
  91. //---------------------------------------------------------------  
  92.   
  93. class CMyEvent: private CEventImpl  
  94. {  
  95. public:  
  96.     CMyEvent(bool bManualReset = true);  
  97.     ~CMyEvent();  
  98.   
  99.     void Set();  
  100.     bool Wait();  
  101.     bool Wait(long milliseconds);  
  102.     bool TryWait(long milliseconds);  
  103.     void Reset();  
  104.   
  105. private:  
  106.     CMyEvent(const CMyEvent&);  
  107.     CMyEvent& operator = (const CMyEvent&);  
  108. };  
  109.   
  110.   
  111. inline void CMyEvent::Set()  
  112. {  
  113.     SetImpl();  
  114. }  
  115.   
  116. inline bool CMyEvent::Wait()  
  117. {  
  118.     return WaitImpl();  
  119. }  
  120.   
  121. inline bool CMyEvent::Wait(long milliseconds)  
  122. {  
  123.     if (!WaitImpl(milliseconds))  
  124.     {  
  125.         cout<<"time out"<<endl;  
  126.         return false;  
  127.     }  
  128.     else  
  129.     {  
  130.         return true;  
  131.     }  
  132. }  
  133.   
  134. inline bool CMyEvent::TryWait(long milliseconds)  
  135. {  
  136.     return WaitImpl(milliseconds);  
  137. }  
  138.   
  139. inline void CMyEvent::Reset()  
  140. {  
  141.     ResetImpl();  
  142. }  
  143.   
  144. #endif  


MyEvent.cpp

[cpp]  view plain  copy
 
  1. #include "MyEvent.h"  
  2. #include <sys/time.h>  
  3.   
  4. CEventImpl::CEventImpl(bool manualReset): m_manual(manualReset), m_state(false)  
  5. {  
  6.     if (pthread_mutex_init(&m_mutex, NULL))  
  7.         cout<<"cannot create event (mutex)"<<endl;  
  8.     if (pthread_cond_init(&m_cond, NULL))  
  9.         cout<<"cannot create event (condition)"<<endl;  
  10. }  
  11.   
  12. CEventImpl::~CEventImpl()  
  13. {  
  14.     pthread_cond_destroy(&m_cond);  
  15.     pthread_mutex_destroy(&m_mutex);  
  16. }  
  17.   
  18. bool CEventImpl::WaitImpl()  
  19. {  
  20.     if (pthread_mutex_lock(&m_mutex))  
  21.     {  
  22.         cout<<"wait for event failed (lock)"<<endl;   
  23.         return false;  
  24.     }  
  25.     while (!m_state)   
  26.     {  
  27.         //cout<<"CEventImpl::WaitImpl while m_state = "<<m_state<<endl;  
  28.   
  29.         //对互斥体进行原子的解锁工作,然后等待状态信号  
  30.         if (pthread_cond_wait(&m_cond, &m_mutex))  
  31.         {  
  32.             pthread_mutex_unlock(&m_mutex);  
  33.             cout<<"wait for event failed"<<endl;  
  34.             return false;  
  35.         }  
  36.     }  
  37.     if (m_manual)  
  38.         m_state = false;  
  39.     pthread_mutex_unlock(&m_mutex);  
  40.   
  41.     //cout<<"CEventImpl::WaitImpl end m_state = "<<m_state<<endl;  
  42.   
  43.     return true;  
  44. }  
  45.   
  46. bool CEventImpl::WaitImpl(long milliseconds)  
  47. {  
  48.     int rc = 0;  
  49.     struct timespec abstime;  
  50.     struct timeval tv;  
  51.     gettimeofday(&tv, NULL);  
  52.     abstime.tv_sec  = tv.tv_sec + milliseconds / 1000;  
  53.     abstime.tv_nsec = tv.tv_usec*1000 + (milliseconds % 1000)*1000000;  
  54.     if (abstime.tv_nsec >= 1000000000)  
  55.     {  
  56.         abstime.tv_nsec -= 1000000000;  
  57.         abstime.tv_sec++;  
  58.     }  
  59.   
  60.     if (pthread_mutex_lock(&m_mutex) != 0)  
  61.     {  
  62.         cout<<"wait for event failed (lock)"<<endl;   
  63.         return false;  
  64.     }  
  65.     while (!m_state)   
  66.     {  
  67.         //自动释放互斥体并且等待m_cond状态,并且限制了最大的等待时间  
  68.         if ((rc = pthread_cond_timedwait(&m_cond, &m_mutex, &abstime)))  
  69.         {  
  70.             if (rc == ETIMEDOUT) break;  
  71.             pthread_mutex_unlock(&m_mutex);  
  72.             cout<<"cannot wait for event"<<endl;  
  73.             return false;  
  74.         }  
  75.     }  
  76.     if (rc == 0 && m_manual)   
  77.         m_state = false;  
  78.     pthread_mutex_unlock(&m_mutex);  
  79.     return rc == 0;  
  80. }  
  81.   
  82. CMyEvent::CMyEvent(bool bManualReset): CEventImpl(bManualReset)  
  83. {  
  84. }  
  85.   
  86. CMyEvent::~CMyEvent()  
  87. {  
  88. }  


    下边是测试代码

[cpp]  view plain  copy
 
  1. // pthread_event.cpp : 定义控制台应用程序的入口点。  
  2. //  
  3.   
  4. #include <unistd.h>  
  5. #include "MyEvent.h"  
  6.   
  7. #define PRINT_TIMES 10  
  8.   
  9. //创建一个人工自动重置事件对象  
  10. CMyEvent g_myEvent;  
  11. int g_iNum = 0;  
  12.   
  13.   
  14. //线程函数1  
  15. void * ThreadProc1(void *pParam)  
  16. {  
  17.     for (int i = 0; i < PRINT_TIMES; i++)  
  18.     {  
  19.         g_iNum++;  
  20.         cout<<"ThreadProc1 do print, Num = "<<g_iNum<<endl;  
  21.   
  22.         //设置事件为有信号状态  
  23.         g_myEvent.Set();  
  24.   
  25.         sleep(1);  
  26.     }  
  27.   
  28.     return (void *)0;  
  29. }  
  30.   
  31. //线程函数2  
  32. void * ThreadProc2(void *pParam)  
  33. {  
  34.     bool bRet = false;  
  35.     while ( 1 )  
  36.     {  
  37.         if ( g_iNum >= PRINT_TIMES )  
  38.         {  
  39.             break;  
  40.         }  
  41.   
  42.         //以当前事件对象阻塞本线程，将其挂起  
  43.         bRet = g_myEvent.Wait();  
  44.         if ( bRet )  
  45.         {  
  46.             cout<<"ThreadProc2 do print, Num = "<<g_iNum<<endl;  
  47.   
  48.             //设置事件为无信号状态  
  49.             g_myEvent.Reset();  
  50.         }  
  51.         else  
  52.         {  
  53.             cout<<"ThreadProc2 system exception"<<endl;  
  54.         }  
  55.     }  
  56.   
  57.     return (void *)0;  
  58. }  
  59.   
  60.   
  61. int main(int argc, char* argv[])  
  62. {  
  63.     pthread_t thread1,thread2;  
  64.     pthread_attr_t attr1,attr2;  
  65.   
  66.   
  67.     //创建两个工作线程  
  68.     pthread_attr_init(&attr1);  
  69.     pthread_attr_setdetachstate(&attr1,PTHREAD_CREATE_JOINABLE);  
  70.     if (pthread_create(&thread1,&attr1, ThreadProc1,NULL) == -1)  
  71.     {  
  72.         cout<<"Thread 1: create failed"<<endl;  
  73.     }  
  74.     pthread_attr_init(&attr2);  
  75.     pthread_attr_setdetachstate(&attr2,PTHREAD_CREATE_JOINABLE);  
  76.     if (pthread_create(&thread2,&attr2, ThreadProc2,NULL) == -1)  
  77.     {  
  78.         cout<<"Thread 2: create failed"<<endl;  
  79.     }  
  80.   
  81.     //等待线程结束  
  82.     void *result;  
  83.     pthread_join(thread1,&result);  
  84.     pthread_join(thread2,&result);  
  85.   
  86.     //关闭线程，释放资源  
  87.     pthread_attr_destroy(&attr1);  
  88.     pthread_attr_destroy(&attr2);  
  89.   
  90.     int iWait;  
  91.     cin>>iWait;  
  92.   
  93.     return 0;  
  94. }  


    编译，运行。可以看到，与Win32平台上的测试结果相同，好神奇！

from:http://blog.csdn.net/chexlong/article/details/7080537 

文章标签：
C++
Linux
调度
API
关键词：
Linux平台
C++线程
线程同步
同步线程
Linux c++
double2li
目录
相关文章
最好zzz
|
15天前
|
缓存 安全 C++
C++无锁队列：解锁多线程编程新境界
【10月更文挑战第27天】
最好zzz
30 7
潇洒洒
|
15天前
|
消息中间件 存储 安全
深入探索C++无锁队列：多线程编程的高效利器
【10月更文挑战第19天】
潇洒洒
62 6
石小浪♪
|
1月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念，包括进程和线程的定义、并发的实现方式，以及如何在C++中创建和管理线程，包括使用`std::thread`库、线程的join和detach方法，并通过示例代码展示了如何创建和使用多线程。
石小浪♪
41 1
C++ 多线程之初识多线程
小王老师呀
|
21天前
|
存储 并行计算 安全
C++多线程应用
【10月更文挑战第29天】C++ 中的多线程应用广泛，常见场景包括并行计算、网络编程中的并发服务器和图形用户界面（GUI）应用。通过多线程可以显著提升计算速度和响应能力。示例代码展示了如何使用 `pthread` 库创建和管理线程。注意事项包括数据同步与互斥、线程间通信和线程安全的类设计，以确保程序的正确性和稳定性。
小王老师呀
23 5
蓝易云
|
1月前
|
Ubuntu Linux 编译器
Linux/Ubuntu下使用VS Code配置C/C++项目环境调用OpenCV
通过以上步骤，您已经成功在Ubuntu系统下的VS Code中配置了C/C++项目环境，并能够调用OpenCV库进行开发。请确保每一步都按照您的系统实际情况进行适当调整。
蓝易云
264 3
石小浪♪
|
1月前
|
存储 前端开发 C++
C++ 多线程之带返回值的线程处理函数
这篇文章介绍了在C++中使用`async`函数、`packaged_task`和`promise`三种方法来创建带返回值的线程处理函数。
石小浪♪
45 6
Ly001122
|
1月前
|
缓存 负载均衡 Java
c++写高性能的任务流线程池(万字详解！)
本文介绍了一种高性能的任务流线程池设计，涵盖多种优化机制。首先介绍了Work Steal机制，通过任务偷窃提高资源利用率。接着讨论了优先级任务，使不同优先级的任务得到合理调度。然后提出了缓存机制，通过环形缓存队列提升程序负载能力。Local Thread机制则通过预先创建线程减少创建和销毁线程的开销。Lock Free机制进一步减少了锁的竞争。容量动态调整机制根据任务负载动态调整线程数量。批量处理机制提高了任务处理效率。此外，还介绍了负载均衡、避免等待、预测优化、减少复制等策略。最后，任务组的设计便于管理和复用多任务。整体设计旨在提升线程池的性能和稳定性。
Ly001122
74 5
石小浪♪
|
1月前
|
C++
C++ 多线程之线程管理函数
这篇文章介绍了C++中多线程编程的几个关键函数，包括获取线程ID的`get_id()`，延时函数`sleep_for()`，线程让步函数`yield()`，以及阻塞线程直到指定时间的`sleep_until()`。
石小浪♪
23 0
C++ 多线程之线程管理函数
石小浪♪
|
1月前
|
资源调度 Linux 调度
Linux C/C++之线程基础
这篇文章详细介绍了Linux下C/C++线程的基本概念、创建和管理线程的方法，以及线程同步的各种机制，并通过实例代码展示了线程同步技术的应用。
石小浪♪
29 0
Linux C/C++之线程基础
奔跑的码仔
|
Linux 程序员 API
Linux 同步机制比较与联系
操作系统提供的同步原语包括：互斥锁、读写锁、条件变量、信号量，支持多任务的OS一般都会实现上述几种同步方式。Linux作为多任务、多用户系统，同样实现了上述几种同步方式。对于在Linux系统下编程的程序员来说，可能都或多或少的使用或者听说过这几种方式，对于它们的基本使用方式可能都大体的解了。
奔跑的码仔
139 0

热门文章

最新文章

  • 1
    一个简单的C#多线程间同步的例子
  • 2
    使用UncaughtExceptionHandler重启线程
  • 3
    Python多线程编程之多线程加锁
  • 4
    多线程中的临界区
  • 5
    线程同步中异常情况的处理
  • 6
    Boost::Thread 多线程的基础知识
  • 7
    线程池系列三：ThreadPoolExecutor讲解
  • 8
    Java || 线程 || 大一新生 || 一篇synchronized锁的知识点总结
  • 9
    我的Java开发学习之旅------&gt;Java多线程下载文件 实例
  • 10
    线程状态&&Wait和sleep的区别？
  • 1
    Linux命令systemctl详解
    151
  • 2
    Linux命令sync详解
    449
  • 3
    Linux命令sum详解
    97
  • 4
    Linux命令su详解
    141
  • 5
    Linux命令stty详解
    385
  • 6
    Linux命令strip详解
    197
  • 7
    Linux命令strings详解
    210
  • 8
    stdbuf命令在Linux中的深度解析
    146
  • 9
    Linux命令stat：深入了解文件与文件系统状态
    222
  • 10
    Linux命令ssltap的深入解析与应用实践
    77

    • 相关课程

    更多
  • Linux用户和组管理
  • 计算机基础与Linux入门
  • Linux基本命令
  • Linux企业运维实战 - 入门及常用命令
  • Linux Shell 编程入门与实战
  • Linux网络进阶 - TCP/IP协议及OSI七层模型

    • 相关电子书

    更多
  • Alibaba Cloud Linux 3 发布
  • ECS系统指南之Linux系统诊断
  • ECS运维指南 之 Linux系统诊断

    • 相关实验场景

    更多
  • 使用计算巢企业应用，一键获取专属的Linux服务器管理软件
  • 部署Linux主机管理系统WDCP
  • 快速配置Linux云服务器
  • 基于Linux命令实现WordPress手动建站
  • Linux系统的安全登录
  • Linux指令入门-文件管理

    • 推荐镜像

    更多
  • mxlinux-iso
  • archlinuxarm
  • archlinuxcn
    • 下一篇
    阿里云OSS设置跨域访问