121 python程序中的线程操作-队列queue

Posted 2022-11-23 xichenhome

一、线程队列

queue队列：使用方法同进程的Queue一样

如果必须在多个线程之间安全地交换信息时，队列在线程编程中尤其有用。

重要：

q.put():往队列里面放值，当参数block=Ture的时候，timeout参数将会有作用，当队列已经满了的时候，在往里面放值时，block为True程序将会等待timeout的时间，过了时间程序会报错，block如果为Flase时，程序不会等待直接报错

q.get():从队列里面取值，当参数block=Ture的时候，timeout参数将会有作用，当队列已经空了的时候，在从里面取值时，block为True程序将会等待timeout的时间，过了时间程序会报错，block如果为Flase时，程序不会等待直接报错

q.task_done()：使用者使用此方法发出信号，表示q.get()返回的项目已经被处理。如果调用此方法的次数大于从队列中删除的项目数量，将引发ValueError异常。

q.join()：生产者将使用此方法进行阻塞，直到队列中所有项目均被处理。阻塞将持续到为队列中的每个项目均调用q.task_done()方法为止。

二、线程队列的取值方式

2.1 先进先出

class queue.Queue(maxsize=0)

q = queue.Queue()：不加参数代表队列可以无限的放数据

q = queue.Queue() #不加参数代表队列可以无限的放数据
q.put('Cecilia陈')
q.put('xichen')

print(q.get())
print(q.get())

'''
结果：
Cecilia陈
xichen
'''

2.2 后进先出

class queue.LifoQueue(maxsize=0)

q = Lifo.Queue()：不加参数代表队列可以无限的放数据

q = queue.LifoQueue() #不加参数代表队列可以无线的放数据
q.put('Cecilia陈')
q.put('xichen')

print(q.get())
print(q.get())
'''
结果：
xichen
Cecilia陈
'''

三、队列存数据时可以设置优先级

class queue.priorityQueue(maxsize=0)

q = queue.priorityQueue()：不加参数代表队列可以无限的放数据

3.1 优先级队列

# 3.优先级队列
q = queue.PriorityQueue() #不加参数代表队列可以无线的放数据
#put进入一个元组,元组的第一个元素是优先级(通常是数字,也可以是非数字之间的比较),数字越小优先级越高
q.put((2,'Cecilia陈'))
q.put((1,'xichen'))
q.put((5,'xuchen'))

print(q.get())
print(q.get())
print(q.get())
'''
# 结果(数字越小优先级越高,优先级高的优先出队):
结果：
(1, 'xichen')
(2, 'Cecilia陈')
(5, 'xuchen')
'''

3.2 方法说明

maxsize是一个整数，它设置可以放置在队列中的项数的上限。一旦达到此大小，插入将阻塞，直到使用队列项。如果maxsize小于或等于零，则队列大小为无穷大。

p.put():放值的时候，放的是一个元组（）

exception queue.Empty:异常队列。空:当对空的队列对象调用非阻塞 get() 或 get_nowait() 时引发异常,也就是说队列为空的时候，再取值就会报错

exception queue.Full:异常队列。Full:当对已满的队列对象调用非阻塞put() 或 put_nowait() 时引发异常。也就是说当队列已满的时候，再往里面当值的时候将会报错

Queue.qsize ():

empty():如果为空，返回True

Queue.full():如果已满，返回True

put_nowait(item):等同于put(item, False)。

get_nowait():等同于get(False)。

提供了两种方法来支持跟踪已加入队列的任务是否已被守护进程使用者线程完全处理:

task_done():表示以前加入队列的任务已经完成。由队列使用者线程使用。对于用于获取任务的每个get()，后续对task_done()的调用告诉队列任务上的处理已经完成。如果join(当前处于阻塞状态，那么在处理完所有项之后，它将继续运行(这意味着对于已经放入队列()的每个项，都收到了task_done()调用)。

如果调用次数超过放置在队列中的项的次数，则引发ValueError。

Queue.join():块直到队列被消费完毕。