Python线程条件变量Condition原理解析
这篇文章主要介绍了Python线程条件变量Condition原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
Condition对象就是条件变量，它总是与某种锁相关联，可以是外部传入的锁或是系统默认创建的锁。当几个条件变量共享一个锁时，你就应该自己传入一个锁。这个锁不需要你操心，Condition类会管理它。
acquire()和release()可以操控这个相关联的锁。其他的方法都必须在这个锁被锁上的情况下使用。wait()会释放这个锁，阻塞本线程直到其他线程通过notify()或notify_all()来唤醒它。一旦被唤醒，这个锁又被wait()锁上。
经典的consumer/producer问题的代码示例为：
importthreading
importtime
importlogging
logging.basicConfig(level=logging.DEBUG,
format='(%(threadName)-9s)%(message)s',)
defconsumer(cv):
logging.debug('Consumerthreadstarted...')
withcv:
logging.debug('Consumerwaiting...')
cv.acquire()
cv.wait()
logging.debug('Consumerconsumedtheresource')
cv.release()
defproducer(cv):
logging.debug('Producerthreadstarted...')
withcv:
cv.acquire()
logging.debug('Makingresourceavailable')
logging.debug('Notifyingtoallconsumers')
cv.notify()
cv.release()
if__name__=='__main__':
condition=threading.Condition()
cs1=threading.Thread(name='consumer1',target=consumer,args=(condition,))
#cs2=threading.Thread(name='consumer2',target=consumer,args=(condition,state))
pd=threading.Thread(name='producer',target=producer,args=(condition,))
cs1.start()
time.sleep(2)
#cs2.start()
#time.sleep(2)
pd.start()
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。