Queue 實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型(實(shí)例講解)

更新時(shí)間：2017年11月13日 08:52:52 作者：有蟲(chóng)子啊

下面小編就為大家?guī)?lái)一篇Queue 實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型(實(shí)例講解)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧

Python中，隊(duì)列是線程間最常用的交換數(shù)據(jù)的形式。

Python Queue模塊有三種隊(duì)列及構(gòu)造函數(shù):

1、Python Queue模塊的FIFO隊(duì)列先進(jìn)先出。 class Queue.Queue(maxsize)

2、LIFO類似于堆，即先進(jìn)后出。 class Queue.LifoQueue(maxsize)

3、還有一種是優(yōu)先級(jí)隊(duì)列級(jí)別越低越先出來(lái)。 class Queue.PriorityQueue(maxsize)

此包中的常用方法(q = Queue.Queue()):

q.qsize() 返回隊(duì)列的大小

q.empty() 如果隊(duì)列為空，返回True,反之False

q.full() 如果隊(duì)列滿了，返回True,反之False

q.full 與 maxsize 大小對(duì)應(yīng)

q.get([block[, timeout]]) 獲取隊(duì)列，timeout等待時(shí)間

q.get_nowait() 相當(dāng)q.get(False)

非阻塞 q.put(item) 寫入隊(duì)列，timeout等待時(shí)間

q.put_nowait(item) 相當(dāng)q.put(item, False)

q.task_done() 在完成一項(xiàng)工作之后，q.task_done() 函數(shù)向任務(wù)已經(jīng)完成的隊(duì)列發(fā)送一個(gè)信號(hào)

q.join() 實(shí)際上意味著等到隊(duì)列為空，再執(zhí)行別的操作

# coding=utf-8

import Queue
import threading
import time


q = Queue.Queue(maxsize=10) # 創(chuàng)建一個(gè)隊(duì)列對(duì)象，長(zhǎng)度限制為10，maxsize小于1就代表無(wú)限制


def producer(name):
  count = 1
  while True:
    q.put(count) # 將值放入隊(duì)列中 默認(rèn)block為True，無(wú)數(shù)據(jù)時(shí)調(diào)用線程暫停，否則拋出異常
    print "%s 生產(chǎn)了包子 %d" % (name, count)
    count += 1
    time.sleep(0.5)


def consumer(name):
  while True:
    conut_con = q.get() # 從隊(duì)列中取值 默認(rèn)block為True，無(wú)數(shù)據(jù)時(shí)調(diào)用線程暫停，否則拋出異常
    print "%s 吃掉了包子 %d" % (name, conut_con)
    time.sleep(2)


pro = threading.Thread(target=producer, args=("德源",))
con = threading.Thread(target=consumer, args=("xu",))
con2 = threading.Thread(target=consumer, args=("sx",))

pro.start()
con.start()
con2.start() # 開(kāi)啟線程

以上這篇Queue 實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模型(實(shí)例講解)就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: