我对自己熟悉QT5并发库.我在看QWaitCondition示例(
http://qt-project.org/doc/qt-5.0/qtcore/qwaitcondition.html#details).
这里,一个线程(线程B)读取用户输入,所有其他线程(线程A)处理此输入.
这里,一个线程(线程B)读取用户输入,所有其他线程(线程A)处理此输入.
线程A:
forever { mutex.lock(); keypressed.wait(&mutex); ++count; mutex.unlock(); do_something(); mutex.lock(); --count; mutex.unlock(); }
线程B:
forever { getchar(); mutex.lock(); // Sleep until there are no busy worker threads while (count > 0) { mutex.unlock(); sleep(1); mutex.lock(); } keypressed.wakeAll(); mutex.unlock(); }
使用count变量和扩展互斥同步的原因是为了防止符号丢失.
问题是,我认为符号可能会丢失:
想象一下以下场景:
>线程A处理符号,并减少反对(–count);
互斥体被释放;然后线程A停止
>线程B从睡眠状态返回,获取互斥锁,看到,计数==
0,并调用keypressed.wakeAll(),然后解锁互斥锁.
然而,wakeAll()调用无处可去,因为线程A是
不等
>线程A再次启动,对互斥体进行aquaires并进入等待().
由于wakeAll()已被调用,因此符号丢失.
我是对的,还是我错过了什么?如果我是对的,如何纠正这个例子以真正阻止它跳过符号?
解决方法
原文地址:https://www.jb51.cc/c/110604.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。