執行緒鎖相當於同時只能有一個執行緒申請鎖，有的場景無資料修改互斥要求可以同時讓多個執行緒同時執行，且需要限制併發執行緒數量時可以使用訊號量

import threading,time,queue

def test(name):
  semaphore.acquire() #獲取訊號量鎖
  print('my name is %s' %name)
  time.sleep(1)
  semaphore.release() #釋放訊號量鎖

semaphore = threading.BoundedSemaphore(5) #建立一個訊號量同時可以執行3個執行緒
for i in range(20):
  t = threading.Thread(target=test,args=(i,))
  t.start()
while threading.active_count() == 1:
  print("all run done")

兩個或者多個執行緒需要互動時，且一個程序需要根據另一執行緒狀態執行對應操作時，可以通過event來設定執行緒狀態達到期望的效果，下面是一個紅綠燈的例子

event = threading.Event() #例項化一個event
def light():
  while True:
    print("紅燈亮了，請停車")
    time.sleep(20) #開始是紅燈20s
    event.set() #紅燈時間到了，設定標誌位
    print("綠燈亮了，請通行")
    time.sleep(30) #持續30s紅燈
    event.clear() #清空標誌位

def car(num):
  while True:
    if event.is_set():#檢測event被設定則執行
      print("car %s run"%num)
      time.sleep(5)
    else:
      print("this is red light waiting")
      event.wait() #此處會卡主，直到狀態被設定才會向下執行



Light = threading.Thread(target=light,)
Light.start()
for i in range(10):
  Car = threading.Thread(target=car,))
  Car.start()

當多個執行緒需要互動資料可以使用queue來進行資料傳遞，下面是經典的生產者消費者多執行緒模型示例，其中包含執行緒queue的基本使用方法

my_queue = queue.Queue() #例項化一個佇列
queue1 = queue.LifoQueue() #後進 先出佇列
queue2 = queue.PriorityQueue() #帶優先順序的佇列
def pro():
  for i in range(100):
    my_queue.put(i) #佇列裡面放資料
def con():
  while my_queue.qsize() > 0: #當佇列有資料時候從佇列取資料
    print("i an a consumer,get num %s"%my_queue.get(timeout=3))
    time.sleep(2)
  else:
    print("my queue is empty")

Pro = threading.Thread(target=pro)
Pro.start()


for j in range(10):
  Con = threading.Thread(target=con)
  Con.start()

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。