我正在学习pthread_cond_wait的基础知识。 在所有的用法中,我也看到了
if(cond is false) pthread_cond_wait
要么
while(cond is false) pthread_cond_wait
我的问题是,我们只想cond_wait,因为条件是错误的。 那么为什么我要明确地把一个if / while循环的痛苦。 我可以理解,没有任何如果/之前检查cond_wait我们将直接打它,它不会返回。 条件检查仅仅是为了解决这个目的还是有其他意义。 如果为了解决不必要的条件等待,那么放一个条件检查,避免cond_wait类似于轮询? 我正在像这样使用cond_wait。
void* proc_add(void *name){ struct vars *my_data = (struct vars*)name; printf("In thread Addition and my id = %dn",pthread_self()); while(1){ pthread_mutex_lock(&mutexattr); while(!my_data->ipt){ // If no input get in pthread_cond_wait(&mutexaddr_add,&mutexattr); // Wait till signalled my_data->opt = my_data->a + my_data->b; my_data->ipt=1; pthread_cond_signal(&mutexaddr_opt); } pthread_mutex_unlock(&mutexattr); if(my_data->end) pthread_exit((void *)0); } }
逻辑是,我要求input线程在input可用时处理数据,并通知输出线程打印它。
如何在不阻塞的情况下同步线程?
在Linux上,如何确保解锁locking在死亡/终止的线程中的互斥锁?
multithreading在c。 互斥
当使用互斥,“printf”输出两次(或更多?我不知道)?
pthread_mutex_timedlock()过早退出而不等待超时
在共同locking文件中的竞争条件?
读写之间的互斥
在Linux中fopen()是一个线程安全的函数吗?
您需要一个while循环,因为即使没有达到您正在等待的条件,调用pthread_cond_wait的线程也可能会唤醒。 这种现象被称为“虚假警报”。
这可能看起来像一个错误,但这是条件变量的实现方式。
这也可以在手册页中找到:
可能会发生来自pthread_cond_timedwait()或pthread_cond_wait()函数的虚假唤醒。 由于从pthread_cond_timedwait()或pthread_cond_wait()返回并不意味着这个谓词的值,所以在返回时谓词应该被重新评估 。
关于实际代码的更新:
void* proc_add(void *name) { struct vars *my_data = (struct vars*)name; printf("In thread Addition and my id = %dn",pthread_self()); while(1) { pthread_mutex_lock(&mutexattr); while(!my_data->ipt){ // If no input get in pthread_cond_wait(&mutexaddr_add,&mutexattr); // Wait till signalled } my_data->opt = my_data->a + my_data->b; my_data->ipt=1; pthread_cond_signal(&mutexaddr_opt); pthread_mutex_unlock(&mutexattr); if(my_data->end) pthread_exit((void *)0); } } }
因为条件变量的信号没有排队(条件变量不是信号量),所以在等待之前必须测试互斥体下的条件。 也就是说,如果线程在该条件变量的pthread_cond_signal()没有线程被阻塞的情况下调用pthread_cond_signal() ,则该信号不执行任何操作。
这意味着如果你有一个线程设置条件:
pthread_mutex_lock(&m); cond = true; pthread_cond_signal(&c); pthread_mutex_unlock(&m);
然后另一个线程无条件等待:
pthread_mutex_lock(&m); pthread_cond_wait(&c,&m); /* cond now true */
这第二个线程将永远阻止。 这是通过让第二个线程检查条件来避免的:
pthread_mutex_lock(&m); if (!cond) pthread_cond_wait(&c,&m); /* cond now true */
由于cond只是用mutex修改的,这意味着当且仅当cond为false时,第二个线程才会等待。
while ()循环用于健壮代码而不是if ()是因为pthread_cond_wait()不能保证它不会被虚假地唤醒。 使用while ()也意味着发信号通知条件变量总是非常安全 – “额外”信号不会影响程序的正确性,这意味着您可以执行一些操作,例如将信号移动到锁定的代码部分之外。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。