Python 多线程 Condition 的使用

ゝ一世哀愁。 2023-05-31 12:08 5阅读 0赞

Condition

Condition（条件变量）通常与一个锁关联。需要在多个Contidion中共享一个锁时，可以传递一个Lock/RLock实例给构造方法，否则它将自己生成一个RLock实例。

可以认为，除了Lock带有的锁定池外，Condition还包含一个等待池，池中的线程处于状态图中的等待阻塞状态，直到另一个线程调用notify()/notifyAll()通知；得到通知后线程进入锁定池等待锁定。

构造方法：  
Condition(\[lock/rlock\])

实例方法：  
acquire(\[timeout\])/release(): 调用关联的锁的相应方法。  
wait(\[timeout\]): 调用这个方法将使线程进入Condition的等待池等待通知，并释放锁。使用前线程必须已获得锁定，否则将抛出异常。  
notify(): 调用这个方法将从等待池挑选一个线程并通知，收到通知的线程将自动调用acquire()尝试获得锁定（进入锁定池）；其他线程仍然在等待池中。调用这个方法不会释放锁定。使用前线程必须已获得锁定，否则将抛出异常。  
notifyAll(): 调用这个方法将通知等待池中所有的线程，这些线程都将进入锁定池尝试获得锁定。调用这个方法不会释放锁定。使用前线程必须已获得锁定，否则将抛出异常。

常见使用:

#coding=utf-8
    __author__ = 'Bruce_Zhou'
    import threading
    import time
    import datetime
    
    num = 0
    con = threading.Condition()
    
    
    class Gov(threading.Thread):
        def __init__(self):
            super(Gov, self).__init__()
    
        def run(self):
            global num
            con.acquire()
            while True:
                print "开始拉升股市"
                num += 1
                print "拉升了" + str(num) + "个点"
                time.sleep(2)
                if num == 5:
                    print "暂时安全！"
                    con.notify()
                    con.wait()
            con.release()
    
    
    class Consumers(threading.Thread):
        def __init__(self):
            super(Consumers, self).__init__()
    
        def run(self):
            global num
            con.acquire()
            while True:
                if num > 0:
                    print "开始打压股市"
                    num -= 1
                    print "打压了" + str(num) + "个点"
                    time.sleep(2)
                    if num == 0:
                        print "你妹的！天台在哪里！"
                        con.notify()
                        con.wait()
            con.release()
    
    if __name__ == '__main__':
        p = Gov()
        c = Consumers()
        p.start()
        c.start()