怎么在Python中使用semaphore evevt實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型

這篇文章給大家介紹怎么在Python中使用semaphore evevt實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

Python的優(yōu)點(diǎn)有哪些

1、簡(jiǎn)單易用，與C/C++、Java、C# 等傳統(tǒng)語言相比，Python對(duì)代碼格式的要求沒有那么嚴(yán)格；2、Python屬于開源的，所有人都可以看到源代碼，并且可以被移植在許多平臺(tái)上使用；3、Python面向?qū)ο?，能夠支持面向過程編程,也支持面向?qū)ο缶幊蹋?、Python是一種解釋性語言，Python寫的程序不需要編譯成二進(jìn)制代碼，可以直接從源代碼運(yùn)行程序；5、Python功能強(qiáng)大，擁有的模塊眾多，基本能夠?qū)崿F(xiàn)所有的常見功能。

線程鎖相當(dāng)于同時(shí)只能有一個(gè)線程申請(qǐng)鎖，有的場(chǎng)景無數(shù)據(jù)修改互斥要求可以同時(shí)讓多個(gè)線程同時(shí)運(yùn)行，且需要限制并發(fā)線程數(shù)量時(shí)可以使用信號(hào)量

import threading, time, queue

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

semaphore = threading.BoundedSemaphore(5) #創(chuàng)建一個(gè)信號(hào)量同時(shí)可以運(yùn)行3個(gè)線程
for i in range(20):
  t = threading.Thread(target=test, args=(i,))
  t.start()
while threading.active_count() == 1:
  print("all run done")

兩個(gè)或者多個(gè)線程需要交互時(shí)，且一個(gè)進(jìn)程需要根據(jù)另一線程狀態(tài)執(zhí)行對(duì)應(yīng)操作時(shí)，可以通過event來設(shè)置線程狀態(tài)達(dá)到期望的效果，下面是一個(gè)紅綠燈的例子

event = threading.Event() #實(shí)例化一個(gè)event
def light():
  while True:
    print("紅燈亮了，請(qǐng)停車")
    time.sleep(20) #開始是紅燈20s
    event.set() #紅燈時(shí)間到了，設(shè)置標(biāo)志位
    print("綠燈亮了，請(qǐng)通行")
    time.sleep(30) #持續(xù)30s紅燈
    event.clear() #清空標(biāo)志位

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



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

當(dāng)多個(gè)線程需要交互數(shù)據(jù)可以使用queue來進(jìn)行數(shù)據(jù)傳遞，下面是經(jīng)典的生產(chǎn)者消費(fèi)者多線程模型示例，其中包含線程queue的基本使用方法

my_queue = queue.Queue() #實(shí)例化一個(gè)隊(duì)列
queue1 = queue.LifoQueue() #后進(jìn) 先出隊(duì)列
queue2 = queue.PriorityQueue() #帶優(yōu)先級(jí)的隊(duì)列
def pro():
  for i in range(100):
    my_queue.put(i) #隊(duì)列里面放數(shù)據(jù)
def con():
  while my_queue.qsize() > 0: #當(dāng)隊(duì)列有數(shù)據(jù)時(shí)候從隊(duì)列取數(shù)據(jù)
    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()

關(guān)于怎么在Python中使用semaphore evevt實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。