Python--Queue

线程队列：

　　先入先出队列、后进先出队列、优先级队列

先入先出：

import queue # 导入模块

q = queue.Queue() # 实例化一个队列
q.put(1) # 向队列中插入数据
q.put(2)
q.put(3)

while True: # 循环取数据
    if q.qsize() != 0: # 当队列大小不为0时则代表队列中有数据
        print(q.get()) # 获取数据并打印
    else:
        break # 当无数据时退出循环

后进先出：

import  queue # 导入模块

# 后进先出
q = queue.LifoQueue() # last in first out
q.put(1)
q.put(2)
q.put(3)

print(q.get()) # 直接取数据，当取不到数据时，程序会阻塞
print(q.get_nowait())  # # 直接取数据，当取不到数据时，程序会报错：_queue.Empty
print(q.get())
print(q.get_nowait())

优先级队列：

import  queue

# 根据消息优先级取数据
q = queue.PriorityQueue() # 实例化优先级队列
q.put((1,'a')) # 向队列中加数据，并设置优先级
q.put((-1,'b'))
q.put((10,'c'))
q.put((3,'z'))

print(q.get_nowait())
print(q.get_nowait())
print(q.get_nowait())
print(q.get_nowait())

# -----------------------------
(-1, 'b')
(1, 'a')
(3, 'z')
(10, 'c')

设置队列空间大小

import  queue
import time
# 设置队列大小
q = queue.Queue(maxsize=8) # 设置队列最大值为8，队列中最多同时存在8条数据

for i in range(10):
    if i < q.maxsize:
        q.put(i)

while q.qsize() != 0:
    print(q.get())
    time.sleep(0.5)

#-----------------------------
0
1
2
3
4
5
6
7

生产者消费者模型示例：

import  threading,time,queue

q = queue.Queue(maxsize=10) # 实例化一个先入先出的队列，并设置队列大小为10


def Producter(name):
    count = 1
    while count <= 20:
        q.put("骨头%s" % count)
        print("%s生产出骨头--%s" % (name,count))
        count += 1

def Consumer(name):
    while True:
        if q.qsize() != 0:
            print("[%s] 取到了骨头[%s]并把它吃了" %(name,q.get()))
            time.sleep(1)
        else:
            print("%s:今天的骨头吃完了，嘤嘤嘤!!!"%name)
            break

yy = threading.Thread(target=Producter,args=('yy',)) #实例化一个生产者线程
tj = threading.Thread(target=Consumer,args=('tj',)) #实例化一个消费者线程
xl = threading.Thread(target=Consumer,args=('xl',)) #实例化另一个消费者线程
yy.start() # 启动生产者线程
tj.start() # 启动消费者线程1
xl.start() # 启动消费者线程2