0

我使用 Qt 4.8.4 和 PyQt 4.10

这是我的测试代码：

#!/usr/bin/env python3

import sys
from PyQt4.QtCore import *
from PyQt4.QtGui import *

class Thread1(QThread):
    def run(self):
        print('thread1 %d' % QThread.currentThreadId())
        mutex.lock()
        QThread.sleep(5)
        mutex.unlock()

class Thread2(QThread):
    def run(self):
        tid = QThread.currentThreadId()
        print('%d tid enters' % tid)
        mutex.lock()
        print(tid)

app = QApplication(sys.argv)

print('main thread %d' % QThread.currentThreadId())
mutex = QMutex()
t = Thread1()
t.start()

QThread.sleep(1)
threads = [Thread2() for i in range(10)]
for thread in threads:
    thread.start()

app.exec()

我的问题是：当 thread1 调用 mutex.unlock() 时，只有一个被阻塞的线程被唤醒。

这是输出：

main thread 140017224202048
thread1 140016996386560
140016987993856 tid enters
140016979601152 tid enters
140016962815744 tid enters
140016971208448 tid enters
140016672044800 tid enters
140016646866688 tid enters
140016638473984 tid enters
140016954423040 tid enters
140016663652096 tid enters
140016655259392 tid enters
140016987993856

该文件没有说明如何唤醒所有被阻止的内容。我怎样才能做到这一点？谢谢

4

3 回答 3

1

根据定义，互斥锁限制（或保护）一段代码，以便一次只有一个线程可以访问它。因此，如果所有线程都等待一个互斥锁，则您不能“​​唤醒”所有线程，也许您需要许多互斥锁（每个“资源”一个）或取决于设计和约束或您的实际项目（因为您从“测试应用程序”）也许信号量会更适合。

于 2013-06-03T14:32:54.127 回答
0

尝试QWaitCondition，您可以使用 condition.wakeAll() 来达到您的目的。

看看等待条件示例。

于 2013-06-03T15:07:11.260 回答
0

不知道你是否还需要这个。但我认为您在 Thread2 类中缺少 mutex.unlock。

您的代码应如下所示：

class Thread2(QThread):
    def run(self):
        tid = QThread.currentThreadId()
        print('%d tid enters' % tid)
        mutex.lock()
        print(tid)
        mutex.unlock() # line Missing
于 2017-01-05T01:58:54.057 回答