admin管理员组文章数量:1599529
Python 多线程 Condition 的使用
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()
版权声明：本文标题：Python 多线程 Condition 的使用 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/dongtai/1728323788a1154171.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。
发表评论