Python queue隊(duì)列原理與應(yīng)用案例分析

更新時(shí)間：2019年09月27日 10:59:48 作者：以夢(mèng)為馬越騎越傻

這篇文章主要介紹了Python queue隊(duì)列原理與應(yīng)用,結(jié)合具體案例形式分析了Python queue隊(duì)列的原理、功能、實(shí)現(xiàn)方法與使用技巧,需要的朋友可以參考下

本文實(shí)例講述了Python queue隊(duì)列原理與應(yīng)用。分享給大家供大家參考，具體如下：

作用：

　　　解耦：使程序直接實(shí)現(xiàn)松耦合，修改一個(gè)函數(shù)，不會(huì)有串聯(lián)關(guān)系。

　　　提高處理效率：ＦＩＦＯ?。健‖F(xiàn)進(jìn)先出，ＬＩＦＯ　＝　后入先出。

隊(duì)列：

　　隊(duì)列可以并發(fā)的派多個(gè)線程，對(duì)排列的線程處理，并切每個(gè)需要處理線程只需要將請(qǐng)求的數(shù)據(jù)放入隊(duì)列容器的內(nèi)存中，線程不需要等待，當(dāng)排列完畢處理完數(shù)據(jù)后，線程在準(zhǔn)時(shí)來(lái)取數(shù)據(jù)即可。請(qǐng)求數(shù)據(jù)的線程只與這個(gè)隊(duì)列容器存在關(guān)系，處理數(shù)據(jù)的線程down掉不會(huì)影響到請(qǐng)求數(shù)據(jù)的線程，隊(duì)列會(huì)派給其他線程處理這分?jǐn)?shù)據(jù)，它實(shí)現(xiàn)了解耦，提高效率。隊(duì)列內(nèi)會(huì)有一個(gè)有順序的容器，列表與這個(gè)容器是有區(qū)別的，列表中數(shù)據(jù)雖然是排列的，但數(shù)據(jù)被取走后還會(huì)保留，而隊(duì)列中這個(gè)容器的數(shù)據(jù)被取后將不會(huì)保留。當(dāng)必須在多個(gè)線程之間安全地交換信息時(shí)，隊(duì)列在線程編程中特別有用。

參數(shù)介紹：

# 先入先出 maxsize 可設(shè)置大小，設(shè)置block=False拋異常
class queue.Queue(maxsize=0)
 # 后進(jìn)先出
class queue.LifoQueue(maxsize=0)
# 存儲(chǔ)數(shù)據(jù)時(shí)可設(shè)置優(yōu)先級(jí)的隊(duì)列
# 優(yōu)先級(jí)設(shè)置數(shù)越小等級(jí)越高
class queue.PriorityQueue(maxsize=0)
# 放入數(shù)據(jù)
Queue.put(item, block=True, timeout=None)
# 取出數(shù)據(jù) #沒(méi)有數(shù)據(jù)將會(huì)等待
Queue.get(block=True, timeout=None)
# 如果1秒后沒(méi)取到數(shù)據(jù)就退出
Queue.get(timeout = 1)
# 取數(shù)據(jù)，如果沒(méi)數(shù)據(jù)拋queue.Empty異常
Queue.get_nowait()
# 查看隊(duì)列大小
Queue.qsize()
# 返回True,如果空
Queue.empty() #return True if empty
# 設(shè)置隊(duì)列大小
Queue.full()
# 后續(xù)調(diào)用告訴隊(duì)列，任務(wù)的處理是完整的。
Queue.task_done()

生產(chǎn)者消費(fèi)者模型：

import threading,time
import queue
# 最多存入10個(gè)
q = queue.Queue(maxsize=10)
def producer(name):
  count = 1
  while True:
      #　生產(chǎn)一塊骨頭
      q.put("骨頭 %s" % count )
      print("生產(chǎn)了骨頭",count)
      count +=1
      time.sleep(0.3)
def consumer(name):
  while True:
    print("%s 取到[%s] 并且吃了它" %(name, q.get()))
    time.sleep(1)
　   # 告知這個(gè)任務(wù)執(zhí)行完了
    q.task_done()
# 生成線程
p = threading.Thread(target=producer,args=("德國(guó)骨科",))
c = threading.Thread(target=consumer,args=("陳狗二",))
d = threading.Thread(target=consumer,args=("呂特黑",))
# 執(zhí)行線程
p.start()
c.start()
d.start()

更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python加密解密算法與技巧總結(jié)》、《Python編碼操作技巧總結(jié)》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》及《Python入門與進(jìn)階經(jīng)典教程》

希望本文所述對(duì)大家Python程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: