我有一个关于多线程同步的问题.. 我们假设我们有2个pthread和一个fifo队列。 线程1将在此队列中插入元素,线程2将从同一队列中提取这些元素。 我实现了我的队列的两个操作:push和pop。然后pthread和同步
void push(element e) {
pthread_mutex_lock(&mutex);
myVector.push_back(e);
pthread_cond_signal(&empty);
pthread_mutex_unlock(&mutex);
}
Element pop() {
pthread_mutex_lock(&mutex);
if(myVector.size() == 0)
pthread_cond_wait(&empty, &mutex);
//extract the element from the queue;
pthread_mutex_unlock(&mutex);
}
的线程2将有这样的生命周期:
while(myBoolFlag) {
Element theElement = myQueue->pop();
usleep(500000);
}
这个代码可以导致死锁的情况呢? 等待之前,我必须解锁互斥锁吗?
这很好,但是您需要使用'while'而不是'if'来检查谓词(请参阅http://stackoverflow.com/q/6206350/768469) – Nemo