Pythoncollections.deque雙邊隊列的原理-創(chuàng)新互聯(lián)

這篇文章將為大家詳細講解有關Python collections.deque雙邊隊列的原理，文章內(nèi)容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

創(chuàng)新互聯(lián)專注于中大型企業(yè)的做網(wǎng)站、網(wǎng)站設計和網(wǎng)站改版、網(wǎng)站營銷服務，追求商業(yè)策劃與數(shù)據(jù)分析、創(chuàng)意藝術與技術開發(fā)的融合，累計客戶數(shù)千家，服務滿意度達97%。幫助廣大客戶順利對接上互聯(lián)網(wǎng)浪潮，準確優(yōu)選出符合自己需要的互聯(lián)網(wǎng)運用，我們將一直專注成都品牌網(wǎng)站建設和互聯(lián)網(wǎng)程序開發(fā)，在前進的路上，與客戶一起成長！

隊列是一種只允許在一端進行插入操作，而在另一端進行刪除操作的線性表。

在Python文檔中搜索隊列（queue）會發(fā)現(xiàn)，Python標準庫中包含了四種隊列，分別是queue.Queue / asyncio.Queue / multiprocessing.Queue / collections.deque。

collections.deque

deque是雙端隊列（double-ended queue）的縮寫，由于兩端都能編輯，deque既可以用來實現(xiàn)棧（stack）也可以用來實現(xiàn)隊列（queue）。

deque支持豐富的操作方法，主要方法如圖：

相比于list實現(xiàn)的隊列，deque實現(xiàn)擁有更低的時間和空間復雜度。list實現(xiàn)在出隊（pop）和插入（insert）時的空間復雜度大約為O(n)，deque在出隊（pop）和入隊（append）時的時間復雜度是O(1)。

deque也支持in操作符，可以使用如下寫法：

q = collections.deque([1, 2, 3, 4])
print(5 in q) # False
print(1 in q) # True

deque還封裝了順逆時針的旋轉的方法：rotate。

# 順時針
q = collections.deque([1, 2, 3, 4])
q.rotate(1)
print(q) # [4, 1, 2, 3]
q.rotate(1)
print(q) # [3, 4, 1, 2]

# 逆時針
q = collections.deque([1, 2, 3, 4])
q.rotate(-1)
print(q) # [2, 3, 4, 1]
q.rotate(-1)
print(q) # [3, 4, 1, 2]

線程安全方面，通過查看collections.deque中的append()、pop()等方法的源碼可以知道，他們都是原子操作，所以是GIL保護下的線程安全方法。

static PyObject *
deque_append(dequeobject *deque, PyObject *item) {
Py_INCREF(item);
if (deque_append_internal(deque, item, deque->maxlen) < 0)
return NULL;
Py_RETURN_NONE;
}

通過dis方法可以看到，append是原子操作（一行字節(jié)碼）。

綜上，collections.deque是一個可以方便實現(xiàn)隊列的數(shù)據(jù)結構，具有線程安全的特性，并且有很高的性能。

queue.Queue & asyncio.Queue

queue.Queue和asyncio.Queue都是支持多生產(chǎn)者、多消費者的隊列，基于collections.deque，他們都提供了Queue（FIFO隊列）、PriorityQueue（優(yōu)先級隊列）、LifoQueue（LIFO隊列），接口方面也相同。

區(qū)別在于queue.Queue適用于多線程的場景，asyncio.Queue適用于協(xié)程場景下的通信，由于asyncio的加成，queue.Queue下的阻塞接口在asyncio.Queue中則是以返回協(xié)程對象的方式執(zhí)行，具體差異如下表：

	queue.Queue	asyncio.Queue
介紹	同步隊列	asyncio隊列
線程安全	是	否
超時機制	通過timeout參數(shù)實現(xiàn)	通過asyncio.wait_for()方法實現(xiàn)
qsize()	預估的隊列長度（獲取qsize到下一個操作之間，queue有可能被其它的線程修改，導致qsize大小發(fā)生變化）	準確的隊列長度（由于是單線程，所以queue不會被其它線程修改）
put() / set()	put(item, block=True, timeout=None)，可以通過設置block是否為True來配置put和set方法是否為阻塞，并且可以為阻塞操作設置大時長timeout，block為False時行為和put_nowait()方法一致。	put()方法會返回一個協(xié)程對象，所以沒有block參數(shù)和timeout參數(shù)，如果需要非阻塞方法，可以使用put_nowait()，如果需要對阻塞方法應用超時，可以使用coroutine asyncio.wait_for()。

multiprocessing.Queue

multiprocessing提供了三種隊列，分別是Queue、SimpleQueue、JoinableQueue。

multiprocessing.Queue既是線程安全也是進程安全的，相當于queue.Queue的多進程克隆版。和threading.Queue很像，multiprocessing.Queue支持put和get操作，底層結構是multiprocessing.Pipe。

multiprocessing.Queue底層是基于Pipe構建的，但是數(shù)據(jù)傳遞時并不是直接寫入Pipe，而是寫入進程本地buffer，通過一個feeder線程寫入底層Pipe，這樣做是為了實現(xiàn)超時控制和非阻塞put/get，所以Queue提供了join_thread、cancel_join_thread、close函數(shù)來控制feeder的行為，close函數(shù)用來關閉feeder線程、join_thread用來join feeder線程，cancel_join_thread用來在控制在進程退出時，不自動join feeder線程，使用cancel_join_thread有可能導致部分數(shù)據(jù)沒有被feeder寫入Pipe而導致的數(shù)據(jù)丟失。

和threading.Queue不同的是，multiprocessing.Queue默認不支持join()和task_done操作，這兩個支持需要使用mp.JoinableQueue對象。

SimpleQueue是一個簡化的隊列，去掉了Queue中的buffer，沒有了使用Queue可能出現(xiàn)的問題，但是put和get方法都是阻塞的并且沒有超時控制。

關于Python collections.deque雙邊隊列的原理就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。

本文題目：Pythoncollections.deque雙邊隊列的原理-創(chuàng)新互聯(lián)
文章網(wǎng)址：http://bm7419.com/article44/ihghe.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設計公司、網(wǎng)站設計、服務器托管、建站公司、移動網(wǎng)站建設、ChatGPT

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)