19、Python之队列

一、队列的基本操作

    队列其实是一种数据结构，或者更本质的说队列其实就是对基本数据结构的封装，我们也可以封装自己的数据结构。队列做大的特点是先进先出FIFO（first in first out），下面我们就看看python中队列的基本操作。

队列的基本操作如下：

import queue

# queue_01 = queue.Queue() #申明一个很大的队列
queue_01 = queue.Queue(2) #申明一个长度为3的队列
queue_01.put(1) #往队列中扔了一个数据
queue_01.put(2)#又往队列中扔了一个数据
queue_01.full() #判断队列是否满了
# queue_01.put(3)#又往队列中扔了一个数据，如果队列满 则阻塞
# queue_01.put(1,block=True)#如果队列满了，不阻塞
# queue_01.put(1,timeout=2)#设置队列阻塞时间为1s
queue_01.get()#从队列中取了一个数据
queue_01.empty() #判断队列是否为空
queue_01.get() #又从队列中取了一个数据
# queue_01.get(block=True) #又从队列中取了一个元素，如果没有就阻塞
# queue_01.get(block=False)#再从队列中取出一个数据，且不要阻塞，直接抛出异常
#queue_01.get(timeout=1)#又从队列中取了一个元素，超时时间为1s

#以下为特殊的队列
q = queue.LifoQueue() #先进后出 --栈
q2 = queue.PriorityQueue()#按照优先级取的队列
q2.put((2,"hello"))
q2.put((1,"python"))
print(q2.get(),q2.get())

二、实例演示，生产者消费者模式

实例代码如下：

import  time,threading,queue

MAX_SIZE = 2
CUR_SIZE = 0
q = queue.Queue()

def producer(name):
    global  MAX_SIZE,CUR_SIZE
    while True:
        time.sleep(0.5)
        q.put(CUR_SIZE)
        print("33[41;1m%s生产了包子%s号33[0m" % (name,CUR_SIZE))
        CUR_SIZE = CUR_SIZE + 1
        if CUR_SIZE > MAX_SIZE:
            print("关门了!")
            break

def consumer(name):
    global MAX_SIZE,CUR_SIZE
    while True:
        if q.qsize() <= 0 and CUR_SIZE<= MAX_SIZE:
            print("%s:没包子吃了，快点!" % name)
            time.sleep(1)
        elif CUR_SIZE>MAX_SIZE and q.qsize() <= 0:
            print("%s:没包子吃喽，回家了！" % name)
            break
        else:
            data = q.get()
            print("%s 取了包子%s好，开始吃起了" % (name, data))
            time.sleep(3)


p = threading.Thread(target=producer,args=("高文祥",))
c = threading.Thread(target=consumer,args=("张惠",))
c_1 = threading.Thread(target=consumer,args=("gwx",))
p.start()
c.start()
c_1.start()

执行结果