python 多线程 fifo/lifo/priority队列(并行编程 9)

import queue

以下三个队列都可以设置最大长度maxsize,默认是无限大

print("-------------queue.Queue----------------")

线程消息队列,FIFO(先进先出)

q = queue.Queue() q.put("one") q.put("two") q.put("three") print(q.get()) print(q.get()) print(q.get()) try: # 队列中没有数据, 会阻塞。 # 阻塞时间到了还没有数据 抛出 queue.Empty 异常 print(q.get(timeout=3)) except queue.Empty as q_e: print('queue empty')

print("-------------queue.LifoQueue----------------")

线程消息队列,LIFO(后进先出)

lq = queue.LifoQueue() lq.put("one") lq.put("two") lq.put("three") print(lq.get()) print(lq.get()) print(lq.get())

print("-------------queue.PriorityQueue----------------")

线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)

pq = queue.PriorityQueue() pq.put((1, "Jet")) pq.put((3, "Jack")) pq.put((2, "Judy")) print(pq.get()) print(pq.get()) print(pq.get())

运行结果：

-------------queue.Queue---------------- one two three queue empty -------------queue.LifoQueue---------------- three two one -------------queue.PriorityQueue---------------- (1, 'Jet') (2, 'Judy') (3, 'Jack')