当前位置: 代码迷 >> 多核软件开发 >> linux 线程同步解决方案
  详细解决方案

linux 线程同步解决方案

热度:8877   发布时间:2013-02-26 00:00:00.0
linux 线程同步
这是unix环境高级编程这本书中一段话,第11章 线程 11.6线程同步

程序清单11-9 使用条件变量

 #include<pthread.h>
 struct msg{
  struct msg *m_next;
 };
 struct msg *workq;
 pthread_cond_t qready = PTHREAD_COND_INITIALIZER;
 pthread_mutex_t qlock = PTHREAD_MUTEX_INITIALIZER;
 
 void process_msg(void){
  struct msg *mp;
   
  for(;;){
  pthread_mutex_lock(&qlock);
  while(workq == NULL)
  pthread_cond_wait(&qready,&qlock);
  mp = workq;
  workq = mp->m_next;
  pthread_mutex_unlock(&qlock);
  }
 }
 
 void enqueue_msg(struct msg *mp){
  pthread_mutex_lock(&qlock);
  mp->m_next = workq;
  workq = mp;
  pthread_mutex_unlock(&qlock);
  pthread_cond_signal(&qready);
}

  条件是工作队列的状态。用互斥量保护条件,在while循环中判断条件。把消息放到工作队列时,需要占有互斥量,但向等待线程发送信号时并不需要占有互斥量。(到这里都能理解,下面的就不理解了)只要线程可以在调用cond_signal之前把消息从队列中拖出,就可以在释放互斥量以后再完成这部分工作。(这里的“这部分工作”,是哪部分工作)因为是在while循环中检查条件,所有不会存在问题:线程醒来,发现队列仍为空,然后返回继续等待。如果代码不能容忍这种竞争,就需要在向线程发送信号的时候占有互斥量。(后两句不能理解)

这是书中原话,标点都一模一样,请各位前辈帮小弟解释一下不能理解的地方,谢谢!!

------解决方案--------------------------------------------------------
这部分工作,是不是指cond_signal

后面讨论的应该就是下面两句话的先后顺序问题
pthread_mutex_unlock(&qlock);
pthread_cond_signal(&qready);
------解决方案--------------------------------------------------------
工作队列:顾名思义要执行的队列表
------解决方案--------------------------------------------------------
只要线程可以在调用cond_signal之前把消息从队列中拖出,就可以在释放互斥量以后再完成这部分工作。(这里的“这部分工作”,是哪部分工作)
其实不用这样逐字看,把pthread_cond_wait(&qready,&qlock);函数弄清楚就很好理解代码了
这部分工作是指对workq指针的操作,只是这里就一句赋值罢了,可以理解为一项具体的工作,
只要线程可以在调用cond_signal之前把消息从队列中拖出:就是说workq不为空,那么就可以释放互斥量,对workq做对应的操作。
因为有whlie循环在,所以pthread_cond_wait(&qready,&qlock);唤醒后仍然会判断workq是否为空,所以十分安全,所以这里pthread_cond_signal(&qready);执行时互斥量可以是已经解除的。
  相关解决方案