码迷,mamicode.com
首页 > 编程语言 > 详细

python基础 - 条件变量

时间:2018-04-13 13:28:30      阅读:200      评论:0      收藏:0      [点我收藏+]

标签:condition   glob   notify   创建   UI   dom   CQ   let   sel   

  有一类线程需要满足条件之后才能够继续执行,Python提供了threading.Condition对象用于条件变量线程的支持,它除了能提供RLock()或Lock()的方法外,还提供了 wait()、notify()、notifyAll()方法。

lock_con=threading.Condition([Lock/Rlock]): 锁是可选选项,不传入锁,对象自动创建一个RLock()。

  • wait():条件不满足时调用,线程会释放锁并进入等待阻塞
  • notify():条件创造后调用,通知等待池激活一个线程
  • notifyAll():条件创造后调用,通知等待池激活所有线程
import threading,time
from random import randint

class Producer(threading.Thread):
    def run(self):
        global L
        while True:
            val=randint(0,100)
            print(‘生产者‘,self.name,":Append"+str(val),L)
            if lock_con.acquire():
                L.append(val)
                lock_con.notify()
                lock_con.release()
            time.sleep(3)

class Consumer(threading.Thread):
    def run(self):
        global L
        while True:
            lock_con.acquire()
            if len(L)==0:
                lock_con.wait()
            print(‘消费者‘,self.name,":Delete"+str(L[0]),L)
            del L[0]
            lock_con.release()
            time.sleep(0.25)

if __name__=="__main__":

    L=[]
    lock_con=threading.Condition() #创建条件变量锁
    threads=[]
    for i in range(5):
        threads.append(Producer())
    threads.append(Consumer())
    for t in threads: #启动5个生产,1个消费线程对象
        t.start()
    for t in threads:
        t.join()

 

python基础 - 条件变量

标签:condition   glob   notify   创建   UI   dom   CQ   let   sel   

原文地址:https://www.cnblogs.com/id19910408/p/8819422.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!