为什么通知/释放 Condition 对象时我的线程没有启动备份？

Question

这个问题与 Python 3.6 有关。

我有一段代码运行线程库中的一个线程，以及程序的主线程。两个线程都访问一个不是线程安全的对象，所以我让它们在使用对象之前锁定Condition 对象。我生成的线程只需要每 5 分钟访问/更新一次该对象，因此循环中有一个 5 分钟的睡眠计时器。

目前，主线程永远不会获得锁。当第二个线程释放Condition 并开始等待sleep() 调用时，主线程永远不会唤醒/获取锁。就好像主线程已经死了一样。

class Loader:
    def __init__(self, q):
        ...
        self.queryLock = threading.Condition()
        ...
        thread = Thread(target=self.threadfunc, daemon=True)
        thread.start()
        ...
        self.run()

    def threadfunc(self):
        ...
        while True:
            self.queryLock.acquire()
            [critical section #1]
            self.queryLock.notify()
            self.queryLock.release()
            sleep(300)

    def run(self):
        ...
        while True:
            ...
            self.queryLock.acquire()
            [critical section #2]
            self.queryLock.notify()
            self.queryLock.release()
            ...

Answer 1

我相信你真的不需要使用条件。看起来一个简单的Lock 可以完成您的工作。您实际上并没有验证是否满足某些条件，也没有使用 Condition 的特殊方法wait()。

---

话虽如此，关于您提供的代码，您的主线程似乎太“快”了，并且在其他线程有机会之前重新获取了锁。 这是您的代码稍作修改的版本，其中主线程稍等片刻，给另一个线程一个机会，它成功获取锁并继续。

class Loader:
    def __init__(self):
        self.queryLock = threading.Condition()
        thread = Thread(target=self.threadfunc, daemon=True)
        thread.start()
        self.run()
    
    def threadfunc(self):
        while True:
            self.queryLock.acquire()
            print("critical section 1")
            time.sleep(1)
            self.queryLock.notify()
            self.queryLock.release()
            time.sleep(5)
    
    def run(self):
        while True:
            self.queryLock.acquire()
            print("critical section 2")
            time.sleep(2)
            self.queryLock.notify()
            self.queryLock.release()
            print("main is waiting a bit")
            time.sleep(1)


Loader()

比赛条件很有趣:)