C++ 多线程编程总结

发表于:2012-5-21 09:49

字体: | 上一篇 | 下一篇 | 我要投稿

 作者:知然    来源:51Testing软件测试网采编

  在开发C++程序时,一般在吞吐量、并发、实时性上有较高的要求。设计C++程序时,总结起来可以从如下几点提高效率:

  ● 并发

  ● 异步

  ● 缓存

  下面将我平常工作中遇到一些问题例举一二,其设计思想无非以上三点。

  1、任务队列

  1.1 以生产者-消费者模型设计任务队列

  生产者-消费者模型是人们非常熟悉的模型,比如在某个服务器程序中,当User数据被逻辑模块修改后,就产生一个更新数据库的任务(produce),投递给IO模块任务队列,IO模块从任务队列中取出任务执行sql操作(consume)。

  设计通用的任务队列,示例代码如下:

  详细实现可参见:http://ffown.googlecode.com/svn/trunk/fflib/include/detail/task_queue_impl.h

  1. void task_queue_t::produce(const task_t& task_) {  
  2.  lock_guard_t lock(m_mutex);  
  3.  if (m_tasklist->empty()){//! 条件满足唤醒等待线程 
  4.  m_cond.signal();  
  5.  }  
  6.  m_tasklist->push_back(task_);  
  7.  }  
  8.  int task_queue_t::comsume(task_t& task_){  
  9.  lock_guard_t lock(m_mutex);  
  10.  while (m_tasklist->empty())//! 当没有作业时,就等待直到条件满足被唤醒{ 
  11.  if (false == m_flag){  
  12.  return -1;  
  13.  }  
  14.  m_cond.wait();  
  15.  }  
  16.  task_ = m_tasklist->front();  
  17.  m_tasklist->pop_front();  
  18.  return 0;  
  19.  }

  1.2 任务队列使用技巧

  1.2.1 IO 与 逻辑分离

  比如网络游戏服务器程序中,网络模块收到消息包,投递给逻辑层后立即返回,继续接受下一个消息包。逻辑线程在一个没有io操作的环境下运行,以保障实时性。示例:

  1. void handle_xx_msg(long uid, const xx_msg_t& msg){  
  2.  logic_task_queue->post(boost::bind(&servie_t::proces, uid, msg));  
  3.  }

  注意,此模式下为单任务队列,每个任务队列单线程。

  1.2.2 并行流水线

  上面的只是完成了io 和 cpu运算的并行,而cpu中逻辑操作是串行的。在某些场合,cpu逻辑运算部分也可实现并行,如游戏中用户A种菜和B种菜两种操作是完全可以并行的,因为两个操作没有共享数据。最简单的方式是A、B相关的操作被分配到不同的任务队列中。示例如下:

  1. void handle_xx_msg(long uid, const xx_msg_t& msg) {  
  2.  logic_task_queue_array[uid % sizeof(logic_task_queue_array)]->post(  
  3.  boost::bind(&servie_t::proces, uid, msg));  
  4.  }

  注意,此模式下为多任务队列,每个任务队列单线程。

31/3123>
《2023软件测试行业现状调查报告》独家发布~

关注51Testing

联系我们

快捷面板 站点地图 联系我们 广告服务 关于我们 站长统计 发展历程

法律顾问:上海兰迪律师事务所 项棋律师
版权所有 上海博为峰软件技术股份有限公司 Copyright©51testing.com 2003-2024
投诉及意见反馈:webmaster@51testing.com; 业务联系:service@51testing.com 021-64471599-8017

沪ICP备05003035号

沪公网安备 31010102002173号