Python 队列Queue和Prior

2024-02-19 03:07| 来源: 网络整理| 查看: 265

Python的Queue模块适用于多线程编程的FIFO实现。它可用于在生产者(producer)和消费者(consumer)之间线程安全(thread-safe)地传递消息或其它数据，因此多个线程可以共用同一个Queue实例。

FIFO: First in, First out.先进先出 LIFO: Last in, First out.后进先出

from queue import Queue#先进先出队列 from queue import PriorityQueue#优先级队列 import time #队列：先进先出 q = Queue()#创建一个空队列，队列大小没有指定 #判断队列是是否为空 #当一个队列为空的时候如果再用get取则会堵塞，所以取队列的时候一般是用到 #get_nowait()方法，这种方法在向一个空队列取值的时候会抛一个Empty异常 #所以更常用的方法是先判断一个队列是否为空，如果不为空则取值 print(q.empty()) #队列的操作：存--put() 取--get() q.put('page1') q.put('page2') q.put('page3') print(q.empty()) #判断队列是否已经满了 print(q.full()) q1 = Queue(3)#在创建队列时，指定队列大小（表示该队列最多能存多少个元素） q1.put('1') q1.put('1') q1.put('1') print(q1.full()) q2 = Queue(3) q2.put('1') q2.put('2') q2.put('3') value = q2.get()#遵循的原则是：先进先出 print(value) print(q2.full()) #存数据---阻塞 q3 = Queue(3) q3.put(1) q3.put(2) q3.put(3) # q3.put(4)#如果队列已经满了，等着（阻塞），一直等到队列腾出空间，然后把值存入到队列当中。 #取数据--阻塞 q4 = Queue(3) q4.put(1) value = q4.get()#1,此时队列为空 print('q4:',value) # value = q4.get()#阻塞，直到队列当中有新值的时候，取出，结束阻塞。 #非阻塞 q5 = Queue(3) q5.put(1) #1.取 print('q5.qsize:',q5.qsize())#当前队列当中的元素个数 #方法1： # while not q5.empty(): # value2 = q5.get(block=False)#block为Ture，表示阻塞，否则为非阻塞。非阻塞就是“强取” # print('q5：',value2) #方法2： while q5.qsize()>0: value2 = q5.get(block=False) print('q5：',value2) print('q5.qsize:',q5.qsize()) #存 q6 = Queue(3) #方法1： # print(q6.maxsize)#得到队列最大容量 # i = 0 # while i

【本文地址】

公司简介

联系我们