隊(duì)列特性：先進(jìn)先出（FIFO)——先進(jìn)隊(duì)列的元素先出隊(duì)列。來源于我們生活中的隊(duì)列（先排隊(duì)的先辦完事）。

Queue模塊最常與threading模塊一起構(gòu)成生產(chǎn)-消費(fèi)者模型，提供了一個(gè)適用于多線程編程的先進(jìn)先出的數(shù)據(jù)結(jié)構(gòu)，即隊(duì)列。

該模塊源碼中包含5個(gè)類：

其中，Empty和Full是兩個(gè)異常類，當(dāng)隊(duì)列的Queue.get(block=0)或者調(diào)用get_nowait()時(shí)，如果隊(duì)列為空，則拋EmptyException異常。

　　　同理，當(dāng)隊(duì)列的Queue.put(block=0)或者調(diào)用put_nowait()時(shí)，如果隊(duì)列為達(dá)到maxsize，則拋FullException異常。

其他三個(gè)類：

Queue類：典型的隊(duì)列模型，F(xiàn)IFO先入先出?！　lass Queue.Queue(maxsize)     maxsize為隊(duì)列長(zhǎng)度，指明了隊(duì)列中能存放的數(shù)據(jù)個(gè)數(shù)的上限。一旦達(dá)到上限，插入會(huì)導(dǎo)致阻                                                                                                                塞，

直到隊(duì)列中的數(shù)據(jù)被消費(fèi)掉。如果maxsize小于或者等于0，隊(duì)列大小沒有限制。

LifoQueue類：繼承自Queue，類似于堆棧，先入后出?！　lass Queue.LifoQueue(maxsize)

PriorityQueue類：繼承自Queue，優(yōu)先級(jí)隊(duì)列，級(jí)別越低越先出來?！　lass Queue.PriorityQueue(maxsize)

所以，只要搞定Queue類，就基本搞定Queue模塊。

Queue類中常用的方法：

Queue.qsize() 　　   　　　　　　返回隊(duì)列的大小
Queue.empty() 　　 　　　　　　如果隊(duì)列為空，返回True,反之False
Queue.full() 　　　　　　　　　　如果隊(duì)列滿了，返回True,反之False
Queue.full 　　　　　　　　　　   與 maxsize 大小對(duì)應(yīng)

Queue.get([block[, timeout]])    獲取隊(duì)列，timeout等待時(shí)間 ，調(diào)用隊(duì)列對(duì)象的get()方法從隊(duì)頭刪除并返回一個(gè)項(xiàng)目?？蛇x參數(shù)為block，默認(rèn)為True。如果隊(duì)列為空且block為True，get()就使調(diào)用線程暫停，直至有項(xiàng)目可用。如果隊(duì)列為空且block為False，隊(duì)列將引發(fā)Empty異常。

Queue.get_nowait()    相當(dāng)于Queue.get(False)

Queue.put(item）

  寫入隊(duì)列，timeout等待時(shí)間 ,調(diào)用隊(duì)列對(duì)象的put()方法在隊(duì)尾插入一個(gè)項(xiàng)目。put()有兩個(gè)參數(shù)，第一個(gè)item為必需的，為插入項(xiàng)目的值；第   二個(gè)block為可選參數(shù)，默認(rèn)為1。如果隊(duì)列當(dāng)前為空且block為1，put()方法就使調(diào)用線程暫停,直到空出一個(gè)數(shù)據(jù)單元。如果block為0，put方法將引發(fā)Full異常。                                            

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

Queue.task_done(）

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

Queue.join()

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

一個(gè)小的練習(xí)實(shí)例：

#coding:utf-8
import random, threading, time
import Queue
'''
實(shí)現(xiàn)了一個(gè)生產(chǎn)線程，用于往隊(duì)列中添加隨機(jī)數(shù)10個(gè)，
實(shí)現(xiàn)了一個(gè)消費(fèi)線程，分別消耗奇數(shù)隨機(jī)數(shù)和偶數(shù)隨機(jī)數(shù)
'''

class producer(threading.Thread):
  def __init__(self,t_name,queue):
    threading.Thread.__init__(self,name=t_name)
    self.data = queue
  def run(self):
    for i in xrange(10):
      random_num = random.randint(1,99)
      print "%s : %s 生產(chǎn)了一個(gè)隨機(jī)數(shù)\033[31;0m %d \033[0m放入隊(duì)列中" % (time.ctime(),self.getName(),random_num)
      self.data.put(random_num)
      time.sleep(1)
    print "生產(chǎn)線程完成??！"


class consumer(threading.Thread):
  def __init__(self,t_name,queue):
    threading.Thread.__init__(self,name=t_name)
    self.data = queue
  def run(self):
    while True:
      try:
        tmp_num = self.data.get(1,5) #定義超時(shí)時(shí)間5秒
        if tmp_num%2 == 0:
          print "%s : %s 消耗了一個(gè)隊(duì)列中的偶數(shù)隨機(jī)數(shù)\033[31;0m %d \033[0m" % (time.ctime(),self.getName(),tmp_num)
          time.sleep(2)
        else:
          print "%s : %s 消耗了一個(gè)隊(duì)列中的奇數(shù)隨機(jī)數(shù)\033[31;0m %d \033[0m" % (time.ctime(), self.getName(), tmp_num)
          time.sleep(2)
      except:
        print "消費(fèi)線程完成?。? #一旦到達(dá)超時(shí)時(shí)間5秒，會(huì)拋異常，break退出循環(huán)
        break


def main():
  queue = Queue.Queue(0)
  pro = producer('Pro', queue)
  con = consumer('Con', queue)
  pro.start()
  con.start()
  pro.join()
  con.join()
  print 'All threads complete!!!'

if __name__ == '__main__':
  main()

感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！

最新評(píng)論