oiy*_*yio 2 c++ pthreads condition-variable
在网上搜索并阅读了stackoverflow上的问题答案后,我找不到我的问题的答案。
该等待在线程B中被调用,它解锁互斥锁,从而允许其他人访问条件变量(用于发出信号)。然后,当在线程A中发出条件变量的信号时,线程B唤醒,线程B再次锁定互斥锁。
当线程A通过信号通知条件变量唤醒线程B时,线程B被唤醒,请锁定互斥锁。
我从教程中了解到,每当发出线程B信号时,它就会立即锁定互斥量。但是,示例与此相反,当线程B被信号通知并唤醒后,线程A继续执行,有时线程B锁定互斥锁。
我的问题是线程B(在下面的示例中为消费者)何时锁定互斥锁?就在线程B接收信号的那一刻?还是取决于线程调度程序?
我没有找到任何解释。
我正在考虑以下示例的情况:
#include <pthread.h>
#include <stdio.h>
pthread_mutex_t mutex;
pthread_cond_t cond;
int buffer[100];
int loops = 5;
int length = 0;
void *producer(void *arg) {
int i,j;
for (i = 0; i < loops; i++) {
pthread_mutex_lock(&mutex);
buffer[length++] = i;
printf("producer length %d\n", length);
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
}
}
void *consumer(void *arg) {
int i;
for (i = 0; i < loops; i++) {
pthread_mutex_lock(&mutex);
while(length == 0) {
printf(" consumer waiting...\n");
pthread_cond_wait(&cond, &mutex);
}
int item = buffer[--length];
printf("Consumer %d\n", item);
pthread_mutex_unlock(&mutex);
}
}
int main(int argc, char *argv[])
{
pthread_mutex_init(&mutex, 0);
pthread_cond_init(&cond, 0);
pthread_t pThread, cThread;
pthread_create(&pThread, 0, producer, 0);
pthread_create(&cThread, 0, consumer, 0);
pthread_join(pThread, NULL);
pthread_join(cThread, NULL);
pthread_mutex_destroy(&mutex);
pthread_cond_destroy(&cond);
return 0;
}
Run Code Online (Sandbox Code Playgroud)
输出:
consumer waiting...
producer length 1
producer length 2
producer length 3
producer length 4
producer length 5
Consumer 4
Consumer 3
Consumer 2
Consumer 1
Consumer 0
Run Code Online (Sandbox Code Playgroud)
提前致谢
条件变量的行为是释放锁并(在原子上)等待,然后在发出线程信号时重新获取锁。在您的代码中,一个线程在按住互斥锁的同时向另一个线程发出信号,这意味着被唤醒的线程将进入互斥锁的等待队列,直到另一线程释放该互斥锁为止。