python多線程之事件Event的使用詳解

# coding:utf-8

import threading
import time

event = threading.Event()


def chihuoguo(name):
  # 等待事件，進入等待阻塞狀態
  print '%s 已經啟動' % threading.currentThread().getName()
  print '小伙伴 %s 已經進入就餐狀態！'%name
  time.sleep(1)
  event.wait()
  # 收到事件后進入運行狀態
  print '%s 收到通知了.' % threading.currentThread().getName()
  print '小伙伴 %s 開始吃咯！'%name

# 設置線程組
threads = []

# 創建新線程
thread1 = threading.Thread(target=chihuoguo, args=("a", ))
thread2 = threading.Thread(target=chihuoguo, args=("b", ))

# 添加到線程組
threads.append(thread1)
threads.append(thread2)

# 開啟線程
for thread in threads:
  thread.start()

time.sleep(0.1)
# 發送事件通知
print '主線程通知小伙伴開吃咯！'
event.set()

# coding:utf-8

import threading
import time

event = threading.Event()


def chiHuoGuo(name):
  # 等待事件，進入等待阻塞狀態
  print '%s 已經啟動' % threading.currentThread().getName()
  print '小伙伴 %s 已經進入就餐狀態！'%name
  time.sleep(1)
  event.wait()
  # 收到事件后進入運行狀態
  print '%s 收到通知了.' % threading.currentThread().getName()
  print '%s 小伙伴 %s 開始吃咯！'%(time.time(), name)


class myThread (threading.Thread):  # 繼承父類threading.Thread
  def __init__(self, name):
    '''重寫threading.Thread初始化內容'''
    threading.Thread.__init__(self)

    self.people = name

  def run(self):  # 把要執行的代碼寫到run函數里面 線程在創建后會直接運行run函數
    '''重寫run方法'''

    chiHuoGuo(self.people)   # 執行任務
    print("qq交流群：226296743")
    print("結束線程: %s" % threading.currentThread().getName())

# 設置線程組
threads = []
# 創建新線程
thread1 = myThread("a")
thread2 = myThread("b")
thread3 = myThread("c")

# 添加到線程組
threads.append(thread1)
threads.append(thread2)
threads.append(thread3)

# 開啟線程
for thread in threads:
  thread.start()

time.sleep(0.1)
# 發送事件通知
print '集合完畢，人員到齊了，開吃咯！'
event.set()