import queue
q = queue.Queue()  # 創(chuàng)建 Queue 隊(duì)列
for i in range(3):
    q.put(i)  # 在隊(duì)列中依次插入0、1、2元素
for i in range(3):
    print(q.get())  # 依次從隊(duì)列中取出插入的元素，數(shù)據(jù)元素輸出順序?yàn)?、1、2

import queue
q = queue.LifoQueue()  # 創(chuàng)建 LifoQueue 隊(duì)列
for i in range(3):
    q.put(i)  # 在隊(duì)列中依次插入0、1、2元素
for i in range(3):
    print(q.get())  # 依次從隊(duì)列中取出插入的元素，數(shù)據(jù)元素輸出順序?yàn)?、1、0

import queue
q = queue.PriorityQueue()  # 創(chuàng)建 PriorityQueue 隊(duì)列
data1 = (1, 'python')
data2 = (2, '-')
data3 = (3, '100')
style = (data2, data3, data1)
for i in style:
    q.put(i)  # 在隊(duì)列中依次插入元素 data2、data3、data1
for i in range(3):
    print(q.get())  # 依次從隊(duì)列中取出插入的元素，數(shù)據(jù)元素輸出順序?yàn)?data1、data2、data3

import queue
q = queue.SimpleQueue()  # 創(chuàng)建 SimpleQueue 隊(duì)列
for i in range(3):
    q.put(i)  # 在隊(duì)列中依次插入0、1、2元素
for i in range(3):
    print(q.get())  # 依次從隊(duì)列中取出插入的元素，數(shù)據(jù)元素輸出順序?yàn)?、1、2

import queue
try:
    q = queue.Queue(3)  # 設(shè)置隊(duì)列上限為3
    q.put('python')  # 在隊(duì)列中插入字符串 'python'
    q.put('-') # 在隊(duì)列中插入字符串 '-'
    q.put('100') # 在隊(duì)列中插入字符串 '100'
    for i in range(4):  # 從隊(duì)列中取數(shù)據(jù)，取出次數(shù)為4次，引發(fā) queue.Empty 異常
        print(q.get(block=False))
except queue.Empty:
    print('queue.Empty')

import queue
try:
    q = queue.Queue(3)  # 設(shè)置隊(duì)列上限為3
    q.put('python')  # 在隊(duì)列中插入字符串 'python'
    q.put('-') # 在隊(duì)列中插入字符串 '-'
    q.put('100') # 在隊(duì)列中插入字符串 '100'
    q.put('stay hungry, stay foolish', block=False)  # 隊(duì)列已滿(mǎn)，繼續(xù)往隊(duì)列中放入數(shù)據(jù)，引發(fā) queue.Full 異常
except queue.Full:
    print('queue.Full')

import queue
q = queue.Queue()
q.put('python-100')  # 在隊(duì)列中插入元素 'python-100'
print(q.qsize())  # 輸出隊(duì)列中元素個(gè)數(shù)為1

import queue
q = queue.Queue()
print(q.empty())  # 對(duì)列為空，返回 True
q.put('python-100')  # 在隊(duì)列中插入元素 'python-100'
print(q.empty())  # 對(duì)列不為空，返回 False

import queue
q = queue.Queue(3)  # 定義一個(gè)長(zhǎng)度為3的隊(duì)列
print(q.full())  # 元素個(gè)數(shù)未達(dá)到上限，返回 False
q.put('python')  # 在隊(duì)列中插入字符串 'python'
q.put('-') # 在隊(duì)列中插入字符串 '-'
q.put('100') # 在隊(duì)列中插入字符串 '100'
print(q.full())  # 元素個(gè)數(shù)達(dá)到上限，返回 True

import queue
try:
    q = queue.Queue(2)  # 設(shè)置隊(duì)列上限為2
    q.put('python')  # 在隊(duì)列中插入字符串 'python'
    q.put('-') # 在隊(duì)列中插入字符串 '-'
    q.put('100', block = True, timeout = 5) # 隊(duì)列已滿(mǎn)，繼續(xù)在隊(duì)列中插入字符串 '100'，等待5秒后會(huì)引發(fā) queue.Full 異常
except queue.Full:
    print('queue.Full')

import queue
try:
    q = queue.Queue(2)  # 設(shè)置隊(duì)列上限為2
    q.put_nowait('python')  # 在隊(duì)列中插入字符串 'python'
    q.put_nowait('-') # 在隊(duì)列中插入字符串 '-'
    q.put_nowait('100') # 隊(duì)列已滿(mǎn)，繼續(xù)在隊(duì)列中插入字符串 '100'，直接引發(fā) queue.Full 異常
except queue.Full:
    print('queue.Full')

import queue
try:
    q = queue.Queue()
    q.get(block = True, timeout = 5) # 隊(duì)列為空，往隊(duì)列中取數(shù)據(jù)時(shí)，等待5秒后會(huì)引發(fā) queue.Empty 異常
except queue.Empty:
    print('queue.Empty')

import queue
try:
    q = queue.Queue()
    q.get_nowait() # 隊(duì)列為空，往隊(duì)列中取數(shù)據(jù)時(shí)直接引發(fā) queue.Empty 異常
except queue.Empty:
    print('queue.Empty')

import queue
q = queue.Queue()
q.put('python')
q.put('-')
q.put('100')
for i in range(3):
    print(q.get())
    q.task_done()  # 如果不執(zhí)行 task_done，join 會(huì)一直處于阻塞狀態(tài)，等待 task_done 告知它數(shù)據(jù)的處理已經(jīng)完成
q.join()

from queue import Queue
import random
import threading
import time
#生產(chǎn)者線(xiàn)程
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 range(5):
? ? ? ? ? ? print ("%s: %s is producing %d to the queue!" %(time.ctime(), self.getName(), i))
? ? ? ? ? ? self.data.put(i) ?# 將生產(chǎn)的數(shù)據(jù)放入隊(duì)列
? ? ? ? ? ? time.sleep(random.randrange(10)/5)
? ? ? ? print ("%s: %s finished!" %(time.ctime(), self.getName()))
#消費(fèi)者線(xiàn)程
class Consumer(threading.Thread):
? ? def __init__(self, t_name, queue):
? ? ? ? threading.Thread.__init__(self, name=t_name)
? ? ? ? self.data=queue
? ? def run(self):
? ? ? ? for i in range(5):
? ? ? ? ? ? val = self.data.get() ?# 拿出已經(jīng)生產(chǎn)好的數(shù)據(jù)
? ? ? ? ? ? print ("%s: %s is consuming. %d in the queue is consumed!" %(time.ctime(), self.getName(), val))
? ? ? ? ? ? time.sleep(random.randrange(5))
? ? ? ? ? ? self.data.task_done() # 告訴隊(duì)列有關(guān)這個(gè)數(shù)據(jù)的任務(wù)已經(jīng)處理完成
? ? ? ? print ("%s: %s finished!" %(time.ctime(), self.getName()))
#主線(xiàn)程
def main():
? ? queue = Queue()
? ? producer = Producer('Pro.', queue)
? ? consumer = Consumer('Con.', queue)
? ? producer.start()
? ? consumer.start()
? ? queue.join() ?# 阻塞，直到生產(chǎn)者生產(chǎn)的數(shù)據(jù)全都被消費(fèi)掉
? ? producer.join() # 等待生產(chǎn)者線(xiàn)程結(jié)束
? ? consumer.join() # 等待消費(fèi)者線(xiàn)程結(jié)束
? ? print ('All threads terminate!')
if __name__ == '__main__':
? ? main()