隊列-Queue

FIFO（先入先出)隊列Queue，LIFO（后入先出）隊列LifoQueue，和優(yōu)先級隊列PriorityQueue。

常用方法：

Queue.qsize() 返回隊列的大小

Queue.empty() 如果隊列為空，返回True,反之False

Queue.full() 如果隊列滿了，返回True,反之False，Queue.full 與 maxsize 大小對應(yīng)

Queue.get(item) 獲取隊列

Queue.get_nowait() 相當(dāng)于Queue.get(False)，非阻塞方法

Queue.put(item) 寫入隊列

Queue.task_done() 在完成一項工作之后，Queue.task_done()函數(shù)向任務(wù)已經(jīng)完成的隊列發(fā)送一個信號。每個get()調(diào)用得到一個任務(wù)，接下來task_done()調(diào)用告訴隊列該任務(wù)已經(jīng)處理完畢。

Queue.join() 實際上意味著等到隊列為空，再執(zhí)行別的操作

Queue隊列方法主要用于我們的進程間的通信。

進程中的通信一個最主要的用途就是用于日后的爬蟲，當(dāng)我們需要爬取5000個網(wǎng)頁的時候，我們需要從瀏覽器首頁獲取所有的靜態(tài)資源（檢查網(wǎng)頁代碼），然后再通過內(nèi)容提取來提取出其中的URL（全局資源定位符），比如：www.baidu.com，這就和生產(chǎn)者消費者模型很相似。

我們來簡單實現(xiàn)"生產(chǎn)者消費者模型"：

進程池-Pool

一、什么是進程池？

在程序?qū)嶋H處理問題過程中，忙時會有成千上萬的任務(wù)需要被執(zhí)行，閑時可能只有零星任務(wù)。那么在成千上萬個任務(wù)需要被執(zhí)行的時候，我們就需要去創(chuàng)建成千上萬個進程么？首先，創(chuàng)建進程需要消耗時間，銷毀進程也需要消耗時間。第二即便開啟了成千上萬的進程，操作系統(tǒng)也不能讓他們同時執(zhí)行，這樣反而會影響程序的效率。因此我們不能無限制的根據(jù)任務(wù)開啟或者結(jié)束進程。那么我們要怎么做呢？

進程池就是先定義一個池子，在里面放上固定數(shù)量的進程，有需求來了，就拿一個池中的進程來處理任務(wù)，等到處理完畢，進程并不關(guān)閉，而是將進程再放回進程池中繼續(xù)等待任務(wù)。如果有很多任務(wù)需要執(zhí)行，池中的進程數(shù)量不夠，任務(wù)就要等待之前的進程執(zhí)行任務(wù)完畢歸來，拿到空閑進程才能繼續(xù)執(zhí)行。也就是說，池中進程的數(shù)量是固定的，那么同一時間最多有固定數(shù)量的進程在運行。這樣不會增加操作系統(tǒng)的調(diào)度難度，還節(jié)省了開閉進程的時間，也一定程度上能夠?qū)崿F(xiàn)并發(fā)效果。

二、程序類型

我們的程序有兩種：計算密集型、IO密集型

計算密集型：充分利用CPU，多線程可以充分利用多核（適合開啟多進程，但不適合開啟很多）

IO密集型：大部分的時間都在阻塞隊列，而不是在運行狀態(tài)（根本不適合開啟多進程）

信號量和多進程的處理方式的差異在于，每n個信號量是同步的，也就是說，如果只設(shè)置了4個信號量，4個用戶先搶占了CPU，那剩余的496個任務(wù)量需要等待前面4個用戶完成了（100%）之后才能夠繼續(xù)進行。而多進程是異步的，但是由于計算機的CPU有限，采用時間片輪轉(zhuǎn)法進行分配工作，所有的進程都有機會同時開始任務(wù)，但一段（細微）時間后，時間片就會分配給其他進程，這樣宏觀上看起來它是同時進行的，但其中涉及到了非常多的計算機的進程調(diào)度，但是信號量和多進程的處理時間需要視情況而定。

進程池在面對這種（做500件衣服）計算密集型的程序時具有非常高的效率，使用進程池不涉及進程調(diào)度，也就不浪費時間，屬于流水線式24h晝夜不息工作模式，做完一件衣服立馬就會接手第二件、第三件......這種方式充分地利用了CPU，不會在創(chuàng)建進程、進程調(diào)度、銷毀進程中浪費時間。

從結(jié)果來看，我們可以發(fā)現(xiàn)，進程池的速度與多進程和信號量比起來那是相當(dāng)?shù)耐廴?。所以該用哪種方法不用多說了吧。



審核編輯：劉清