import queue
q = queue.Queue()   # 生成先入先出队列实例
q.put(1)  # 先放进1，再放入2
q.put(2)
print(q.get())  # # 输出
1

import queue
q = queue.LifoQueue()   # 生成后入先出队列实例
q.put(1)  # 先放进1，再放入2
q.put(2)
print(q.get())  ## 输出
2

import queue
q = queue.PriorityQueue()
q.put((1, "d1"))
q.put((-1, "d2"))
q.put((6, "d3"))
print(q.get())
print(q.get())
print(q.get())#执行结果
(-1, 'd2')
(1, 'd1')
(6, 'd3')

1、exception queue.Empty
当队列中的数据为空时，就会抛出这个异常。>>> import queue
>>> q = queue.Queue()
>>> q.get(block=False)   #获取不到的时候
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 161, in getraise Empty
queue.Empty###############################################
2、 exception queue.Full
当队列中满了以后，再放数据的话，就会抛出此异常。>>> import queue
>>> q = queue.Queue(maxsize=1)  #创建队列实例，并且设置最大值为1
>>> q.put(1)
>>> q.put(1,block=False)
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 130, in putraise Full
queue.Full###############################################
3、Queue.qsize()
查看队列的大小>>> import queue
>>> q = queue.Queue()
>>> q.put(1)
>>> q.qsize()   #查看队列的大小
1###############################################
4、Queue.empty()
队列如果为空返回True，不为空返回False>>> import queue
>>> q = queue.Queue()
>>> q.put(1)
>>> q.empty()  #队列不为空
False
>>> q.get()
1
>>> q.empty() #队列为空
True###############################################
5、Queue.full()
队列如果满了，返回True，没有满返回False>>> import queue
>>> q = queue.Queue(maxsize=1)  #设置队列的大小为1
>>> q.full()   #队列没有满
False
>>> q.put(1)
>>> q.full()   #队列已满
True###############################################
6、Queue.put(item,block=True,timeout=None)
把数据插入队列中。block参数默认为true，timeout默认值是None。如果blcok为false的话，那么在put时候超过设定的maxsize的值，就会报full 异常。如果timeout设置值得话，说明put值得个数超过maxsize值，那么会在timeout几秒之后抛出full异常。>>> import queue
>>> q = queue.Queue(maxsize=1)  #是定队列的大小为1
>>> q.put(1)
>>> q.put(1,block=False)   #block不会阻塞，会full异常
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 130, in putraise Full
queue.Full
>>> q.put(1,timeout=1)    #超过1秒，则会报full异常
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 141, in putraise Full
queue.Full###############################################
7、Queue.put_nowait(item)
这个其实等同于Queue.put(item,block=False)或者是Queue.put(item,False)>>> import queue
>>> q = queue.Queue(maxsize=1)
>>> q.put(1)
>>> q.put_nowait(1)   #等同于q.put(1,block=False)
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 184, in put_nowaitreturn self.put(item, block=False)File "D:\Python\Python35\lib\queue.py", line 130, in putraise Full
queue.Full###############################################
8、Queue.get(block=True,timeout=None)
移除并返回队列中的序列。参数block=true并且timeout=None。如果block=false的话，那么队列为空的情况下，就直接Empty异常。如果timeout有实际的值，这个时候队列为空，执行get的时候，则时隔多长时间则报出Empty的异常。>>> import queue
>>> q = queue.Queue()
>>> q.put(1)
>>> q.get()
1
>>> q.get(block=False)    #获取不到值，直接抛Empty异常
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 161, in getraise Empty
queue.Empty
>>> q.get(timeout=1)    #设置超时时间，抛出Empty异常
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 172, in getraise Empty
queue.Empty###############################################
9、Queue.get_nowait(item)
其实这个等同于Queue.get(block=False)或者Queue.get(False)>>> import queue
>>> q = queue.Queue()
>>> q.put(1)
>>> q.get()
1
>>> q.get_nowait()   #等同于q.get(block=False)
Traceback (most recent call last):File "<input>", line 1, in <module>File "D:\Python\Python35\lib\queue.py", line 192, in get_nowaitreturn self.get(block=False)File "D:\Python\Python35\lib\queue.py", line 161, in getraise Empty
queue.Empty###############################################
10、Queue.task_done()
get()用于获取任务，task_done()则是用来告诉队列之前获取的任务已经处理完成###############################################
11、Queue.join()
block(阻塞)直到queue（队列）被消费完毕
如果生产者生产10个包子，那么要等消费者把这个10个包子全部消费完毕，生产者才能继续往下执行。

import threading
import queuedef producer():"""模拟生产者:return:"""for i in range(10):q.put("骨头 %s" % i)print("开始等待所有的骨头被取走...")q.join()  # 等待这个骨头队列被消费完毕print("所有的骨头被取完了...")def consumer(n):"""模拟消费者:return:"""while q.qsize() > 0:print("%s 取到" % n, q.get())q.task_done()  # 每去到一个骨头，便告知队列这个任务执行完了q = queue.Queue()p = threading.Thread(target=producer,)
p.start()c1 = consumer("QQ")

import time,random
import queue,threading
q = queue.Queue()def producer(name):count = 0while count < 20:time.sleep(random.randrange(3))q.put(count)  # 在队列里放包子print('Producer %s has produced %s baozi..' % (name, count))count += 1def consumer(name):count = 0while count < 20:time.sleep(random.randrange(4))if not q.empty():  # 如果还有包子data = q.get()  # 就继续获取保证print(data)print('\033[32;1mConsumer %s has eat %s baozi...\033[0m' % (name, data))else:print("-----no baozi anymore----")count += 1p1 = threading.Thread(target=producer, args=('A',))
c1 = threading.Thread(target=consumer, args=('B',))
p1.start()
c1.start()