qwe3223678qwe 发表于 2018-8-6 09:57:03

Python35 events(事件)、队列

基于event实现绿灯举例的多线程 程序  import time
  import threading
  event = threading.Event()
  def lighter():
  count = 0
  event.set()
  ##先设置标志位为真,表示初始状态就是绿灯。否则当下面的if count > 5之前,标志位都是没有被设置的
  while True:
  if count > 5 and count <10: #大于5并且小于10就改成红灯
  # 这里代码不能只写成if count > 5,因为只要满足大于5,就不会去匹配大于10的elif条件了。
  event.clear()   #把标志位清空,检查标志位,如果标志位没有被设置,则当做红灯。
  print ("\033[41;1m red light is on...\033[0m")
  ## 这里>5 and <10的数是6-9,所以这里会打印红灯4次。
  elif count > 10:    #红灯到绿灯期间设置时间为10秒,当大于30时,设置标志位
  event.set() #设置标志位,检查到这个标志位,就当做已经绿灯
  count = 0   #用count来计数多少秒,当设置为绿灯时就清空为0秒,20秒后就红灯
  else:
  print("\033[42;1m green light is on...\033[0m")
  ## 匹配count既不大于5,也不大于10时(也就是小于5时),打印绿灯亮
  ## 这里0-5会打印绿灯6次。
  time.sleep(1)   #设置每一秒循环一次,这样20秒后就红灯,20秒到30秒后就变成绿灯。
  count += 1
  def car(name):
  while True:
  if event.is_set():#这里判断如果事件设置了标志位(表示绿灯)
  print ("[%s] running..." %name)
  time.sleep(1)
  else:   #标志位为空表示红灯
  print ("[%s] sees red light, waiting......" %name)
  event.wait()    #如果判断标志位为空,则阻塞程序,直到标志位为真。
  print ("[%s] green light is on, start going... "%name)
  light = threading.Thread(target=lighter,)
  light.start()
  car1 = threading.Thread(target=car,args=("car1",))
  car1.start()
页: [1]
查看完整版本: Python35 events(事件)、队列