queue库提供了一个适用于多线程编程的先进先出（FIFO）数据结构，可以用来在生产者与消费者线程之间安全地传递消息或其他数据。
它会为调用者处理锁定，使多个线程可以安全而更容易地处理同一个Queue实例。Queue的大小可能受限，以限制内存使用或处理。
基本用法Queue类实现了一个基本的先进先出容器。使用put()将元素增加到这个序列的一端，使用get()从另一端删除。具体代码如下所示：
importqueueq=queue.Queue()foriinrange(1,10):q.put(i)whilenotq.empty():print(q.get(),end="")
运行之后，效果如下：
基本用法这里我们依次添加1到10到队列中，因为先进先出，所以出来的顺序也与添加的顺序相同。
LIFO队列既然有先进先出队列queue，那么数据结构中肯定也有后进先出的队列。后进先出的队列为：LifoQueue，示例如下：
importqueueq=queue.LifoQueue()foriinrange(1,10):q.put(i)whilenotq.empty():print(q.get(),end="")
运行之后，效果如下：
后进先出优先队列在操作系统中，我们常常会根据优先级来处理任务，比如系统的优先级最高，我们肯定优先处理系统任务，然后才处理用户的任务。同样，queue库给我们提供了PriorityQueue来处理优先级的队列。
示例如下：
importqueueimportthreadingclassJob:def__init__(self,priority,desc):self.priority=priorityself.desc=descprint("NewJob:",desc)returndef__eq__(self,other):try:returnself.priority==other.priorityexceptAttributeError:returnNotImplementeddef__lt__(self,other):try:returnself.priorityother.priorityexceptAttributeError:returnNotImplementeddefprocess_Job(q):whileTrue:next_job=q.get()print(next_job.desc)q.task_done()q=queue.PriorityQueue()q.put(Job(5,"FiveJob"))q.put(Job(15,"FifteenJob"))q.put(Job(1,"OneJob"))workers=[threading.Thread(target=process_Job,args=(q,)),threading.Thread(target=process_Job,args=(q,)),]forworkinworkers:work.setDaemon(True)work.start()q.join()
运行之后，效果如下：
优先级这里，我们默认数值越大优先级越高，可以看到15先执行，然后再是5，1任务。这个例子展现了有多个线程在处理任务时，要根据get()时队列中元素的优先级来处理。
预览时标签不可点收录于话题#个上一篇下一篇