作用：

　　　解耦：使程序直接实现松耦合，修改一个函数，不会有串联关系。

　　　提高处理效率：ＦＩＦＯ　＝　现进先出，ＬＩＦＯ　＝　后入先出。

 

队列：

　　队列可以并发的派多个线程，对排列的线程处理，并切每个需要处理线程只需要将请求的数据放入队列容器的内存中，线程不需要等待，当排列完毕处理完数据后，线程在准时来取数据即可。请求数据的线程只与这个队列容器存在关系，处理数据的线程down掉不会影响到请求数据的线程，队列会派给其他线程处理这分数据，它实现了解耦，提高效率。队列内会有一个有顺序的容器，列表与这个容器是有区别的，列表中数据虽然是排列的，但数据被取走后还会保留，而队列中这个容器的数据被取后将不会保留。当必须在多个线程之间安全地交换信息时，队列在线程编程中特别有用。

1、队列有顺序的容器
2、队列数据只有一份，取出来就没了
3、队列数据放在内存里

 

Python三种类型的队例：

Queue：FIFO 即first in first out 先进先出
LifoQueue：LIFO 即last in first out 后进先出
PriorityQueue：优先队列，级别越低，越优先

参数介绍：

# 先入先出 maxsize 可设置大小，设置block=False抛异常
class queue.Queue(maxsize=0)  # 后进先出 
class queue.LifoQueue(maxsize=0)# 存储数据时可设置优先级的队列
# 优先级设置数越小等级越高
class queue.PriorityQueue(maxsize=0) # 放入数据
Queue.put(item, block=True, timeout=None)# 取出数据 #没有数据将会等待
Queue.get(block=True, timeout=None)# 如果1秒后没取到数据就退出
Queue.get(timeout = 1)# 取数据，如果没数据抛queue.Empty异常
Queue.get_nowait()# 查看队列大小
Queue.qsize()# 返回True,如果空
Queue.empty() #return True if empty  # 设置队列大小
Queue.full() # 后续调用告诉队列，任务的处理是完整的。
Queue.task_done()#print(q.get())#取不到会一直等着，卡着了
#print(q.get(timeout=5))#取不到卡5s,抛出异常
#print(q.get(block=True))#取不到会一直等着，卡着了
#print(q.get(block=False))#取不到会抛异常
#print(q.get_nowait())#取不到抛异常

队列的几种类型实例：import  queue,time,threading
q=queue.Queue()#先入先出，默认未限制大小
q=queue.Queue(maxsize=3)#可存入3个数
q.put('王荔1')#存数据，如果存满了一直卡着
q.put('王荔2')
q.put('王荔3')
print("当前队列剩余%s个"%(q.qsize()))#查当前队列大小
print(q.get())
print(q.get())
print(q.get())
print("当前队列剩余%s个"%(q.qsize()))#先入后出
q=queue.LifoQueue()#先入后出
q.put(1)
q.put(2)
q.put(3)
print("当前队列剩余%s个"%(q.qsize()))
print(q.get())
print(q.get())
print(q.get())
print("当前队列剩余%s个"%(q.qsize()))#可设置优先取出
q=queue.PriorityQueue()
q.put((-1,"王荔"))
q.put((2,"橙子"))
q.put((3,"橙汁"))
print("当前队列剩余%s个"%(q.qsize()))
print(q.get())
print(q.get())
print(q.get())
print("当前队列剩余%s个"%(q.qsize()))C:\Users\wangli\PycharmProjects\AutoMation\venv\Scripts\python.exe C:/Users/wangli/PycharmProjects/AutoMation/case/test.py
当前队列剩余3个
王荔1
王荔2
王荔3
当前队列剩余0个
当前队列剩余3个
3
2
1
当前队列剩余0个
当前队列剩余3个
(-1, '王荔')
(2, '橙子')
(3, '橙汁')
当前队列剩余0个Process finished with exit code 0

 

 

#生产者与消费者模型实例：import threading,time
import queue
q = queue.Queue(maxsize=10)
def Producer(name):count = 1while True:q.put("骨头%s" % count)print("生产了骨头",count)count +=1time.sleep(0.1)
def  Consumer(name):while True:print("[%s] 取到[%s] 并且吃了它..." %(name, q.get()))time.sleep(1)
p = threading.Thread(target=Producer,args=("Alex",))
c = threading.Thread(target=Consumer,args=("ChengRonghua",))
c1 = threading.Thread(target=Consumer,args=("王森",))
p.start()
c.start()
c1.start()C:\Users\wangli\PycharmProjects\AutoMation\venv\Scripts\python.exe C:/Users/wangli/PycharmProjects/AutoMation/case/test.py
生产了骨头 1
[ChengRonghua] 取到[骨头1] 并且吃了它...
生产了骨头 2
[王森] 取到[骨头2] 并且吃了它...
生产了骨头 3
生产了骨头 4
生产了骨头 5
生产了骨头 6
生产了骨头 7
生产了骨头 8
生产了骨头 9
生产了骨头 10
[ChengRonghua] 取到[骨头3] 并且吃了它...
生产了骨头 11
[王森] 取到[骨头4] 并且吃了它...
生产了骨头 12
生产了骨头 13
生产了骨头 14
[ChengRonghua] 取到[骨头5] 并且吃了它...
生产了骨头 15
[王森] 取到[骨头6] 并且吃了它...
生产了骨头 16
[ChengRonghua] 取到[骨头7] 并且吃了它...
生产了骨头 17
[王森] 取到[骨头8] 并且吃了它...
生产了骨头 18Process finished with exit code -1