当前位置: 技术问答>linux和unix
linux 线程同步
来源: 互联网 发布时间:2016-12-22
本文导语: 这是unix环境高级编程这本书中一段话,第11章 线程 11.6线程同步 程序清单11-9 使用条件变量 #include struct msg{ struct msg *m_next; }; struct msg *workq; pthread_cond_t qready = PTHREAD_COND_INITIALIZER; pthread_mutex_t...
这是unix环境高级编程这本书中一段话,第11章 线程 11.6线程同步
程序清单11-9 使用条件变量
#include
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循环中检查条件,所有不会存在问题:线程醒来,发现队列仍为空,然后返回继续等待。如果代码不能容忍这种竞争,就需要在向线程发送信号的时候占有互斥量。(后两句不能理解)
这是书中原话,标点都一模一样,请各位前辈帮小弟解释一下不能理解的地方,谢谢!!
程序清单11-9 使用条件变量
#include
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_cond_wait(&qready,&qlock);函数弄清楚就很好理解代码了
这部分工作是指对workq指针的操作,只是这里就一句赋值罢了,可以理解为一项具体的工作,
只要线程可以在调用cond_signal之前把消息从队列中拖出:就是说workq不为空,那么就可以释放互斥量,对workq做对应的操作。
因为有whlie循环在,所以pthread_cond_wait(&qready,&qlock);唤醒后仍然会判断workq是否为空,所以十分安全,所以这里pthread_cond_signal(&qready);执行时互斥量可以是已经解除的。
其实不用这样逐字看,把pthread_cond_wait(&qready,&qlock);函数弄清楚就很好理解代码了
这部分工作是指对workq指针的操作,只是这里就一句赋值罢了,可以理解为一项具体的工作,
只要线程可以在调用cond_signal之前把消息从队列中拖出:就是说workq不为空,那么就可以释放互斥量,对workq做对应的操作。
因为有whlie循环在,所以pthread_cond_wait(&qready,&qlock);唤醒后仍然会判断workq是否为空,所以十分安全,所以这里pthread_cond_signal(&qready);执行时互斥量可以是已经解除的。
|
这部分工作,是不是指cond_signal
后面讨论的应该就是下面两句话的先后顺序问题
pthread_mutex_unlock(&qlock);
pthread_cond_signal(&qready);
后面讨论的应该就是下面两句话的先后顺序问题
pthread_mutex_unlock(&qlock);
pthread_cond_signal(&qready);
|
工作队列:顾名思义要执行的队列表