一、基本用法
Queue類實現了一個基本的先進先出容器。使用put()將元素增加到這個序列的一端,使用get()從另一端刪除。具體代碼如下所示:
import queue
q = queue.Queue()
for i in range(1, 10):
q.put(i)
while not q.empty():
print(q.get(), end=" ")
運行之后,效果如下:

這里我們依次添加1到10到隊列中,因為先進先出,所以出來的順序也與添加的順序相同。
二、LIFO隊列
既然有先進先出隊列queue,那么數據結構中肯定也有后進先出的隊列。后進先出的隊列為:LifoQueue,示例如下:
import queue
q = queue.LifoQueue()
for i in range(1, 10):
q.put(i)
while not q.empty():
print(q.get(), end=" ")
運行之后,效果如下:

三、優先隊列
在操作系統中,我們常常會根據優先級來處理任務,比如系統的優先級最高,我們肯定優先處理系統任務,然后才處理用戶的任務。同樣,queue庫給我們提供了PriorityQueue來處理優先級的隊列。
示例如下:
import queue
import threading
class Job:
def __init__(self, priority, desc):
self.priority = priority
self.desc = desc
print("New Job:", desc)
return
def __eq__(self, other):
try:
return self.priority == other.priority
except AttributeError:
return NotImplemented
def __lt__(self, other):
try:
return self.priority > other.priority
except AttributeError:
return NotImplemented
def process_Job(q):
while True:
next_job = q.get()
print(next_job.desc)
q.task_done()
q = queue.PriorityQueue()
q.put(Job(5, "Five Job"))
q.put(Job(15, "Fifteen Job"))
q.put(Job(1, "One Job"))
workers = [
threading.Thread(target=process_Job, args=(q,)),
threading.Thread(target=process_Job, args=(q,)),
]
for work in workers:
work.setDaemon(True)
work.start()
q.join()
運行之后,效果如下:

這里,我們默認數值越大優先級越高,可以看到15先執行,然后再是5,1任務。這個例子展現了有多個線程在處理任務時,要根據get()時隊列中元素的優先級來處理。
到此這篇關于Python數據結構之優先級隊列queue用法詳解的文章就介紹到這了,更多相關Python隊列queue 內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家!
您可能感興趣的文章:- Python 數據結構之樹的概念詳解
- python三種數據結構及13種創建方法總結
- python數據結構的排序算法
- Python內置數據結構列表與元組示例詳解
- Python二進制數據結構Struct的具體使用
- python用sqlacodegen根據已有數據庫(表)結構生成對應SQLAlchemy模型
- Python數據結構之圖的存儲結構詳解
- Python數據結構之二叉排序樹的定義、查找、插入、構造、刪除
- 詳解python數據結構之棧stack
- Python數據結構詳細