運(yùn)行此代碼應(yīng)該產(chǎn)生以下輸出：

注意：我們將使用Python 3作為這些例子。

使用隊(duì)列運(yùn)行多個(gè)函數(shù)

作為數(shù)據(jù)結(jié)構(gòu)，隊(duì)列是非常普遍的，并且以多種方式存在。 它被組織為先進(jìn)先出（FIFO）或先進(jìn)先出（LIFO）/堆棧，以及有和沒有優(yōu)先級(jí)（優(yōu)先級(jí)隊(duì)列）。 數(shù)據(jù)結(jié)構(gòu)被實(shí)現(xiàn)為具有固定數(shù)量條目的數(shù)組，或作為包含可變數(shù)量的單個(gè)元素的列表。

在列表2.1-2.7中，我們使用FIFO隊(duì)列。 它被實(shí)現(xiàn)為已經(jīng)由來自multiprocessing模塊的相應(yīng)類提供的列表。此外，time模塊被加載并用于模擬工作負(fù)載。

清單2.1：要使用的模塊

接下來，定義一個(gè)worker函數(shù)（清單2.2）。 該函數(shù)實(shí)際上代表代理，需要三個(gè)參數(shù)。進(jìn)程名稱指示它是哪個(gè)進(jìn)程，tasks和results都指向相應(yīng)的隊(duì)列。

在工作函數(shù)里面是一個(gè)while循環(huán)。tasks和results都是在主程序中定義的隊(duì)列。tasks.get()從要處理的任務(wù)隊(duì)列中返回當(dāng)前任務(wù)。小于0的任務(wù)值退出while循環(huán)，返回值為-1。任何其他任務(wù)值都將執(zhí)行一個(gè)計(jì)算（平方），并返回此值。將值返回到主程序?qū)崿F(xiàn)為result.put()。這將在results隊(duì)列的末尾添加計(jì)算值。

清單2.2：worker函數(shù)

下一步是主循環(huán)（參見清單2.3）。首先，定義了進(jìn)程間通信（IPC）的經(jīng)理。接下來，添加兩個(gè)隊(duì)列，一個(gè)保留任務(wù)，另一個(gè)用于結(jié)果。

?

清單2.3：IPC和隊(duì)列

完成此設(shè)置后，我們定義一個(gè)具有四個(gè)工作進(jìn)程（代理）的進(jìn)程池。我們使用類multiprocessing.Pool()，并創(chuàng)建一個(gè)它的實(shí)例。 接下來，我們定義一個(gè)空的進(jìn)程列表（見清單2.4）。

?

清單2.4：定義一個(gè)進(jìn)程池

?

作為以下步驟，我們啟動(dòng)了四個(gè)工作進(jìn)程（代理）。 為了簡單起見，它們被命名為“P0”到“P3”。使用multiprocessing.Pool()完成創(chuàng)建四個(gè)工作進(jìn)程。這將它們中的每一個(gè)連接到worker功能以及任務(wù)和結(jié)果隊(duì)列。 最后，我們?cè)谶M(jìn)程列表的末尾添加新初始化的進(jìn)程，并使用new_process.start()啟動(dòng)新進(jìn)程（參見清單2.5）。

清單2.5：準(zhǔn)備worker進(jìn)程

?

我們的工作進(jìn)程正在等待工作。我們定義一個(gè)任務(wù)列表，在我們的例子中是任意選擇的整數(shù)。這些值將使用tasks.put()添加到任務(wù)列表中。每個(gè)工作進(jìn)程等待任務(wù)，并從任務(wù)列表中選擇下一個(gè)可用任務(wù)。 這由隊(duì)列本身處理（見清單2.6）。

清單2.6：準(zhǔn)備任務(wù)隊(duì)列

?

過了一會(huì)兒，我們希望我們的代理完成。 每個(gè)工作進(jìn)程對(duì)值為-1的任務(wù)做出反應(yīng)。 它將此值解釋為終止信號(hào)，此后死亡。 這就是為什么我們?cè)谌蝿?wù)隊(duì)列中放置盡可能多的-1，因?yàn)槲覀冇羞M(jìn)程運(yùn)行。 在死機(jī)之前，終止的進(jìn)程會(huì)在結(jié)果隊(duì)列中放置-1。 這意味著是代理正在終止的主循環(huán)的確認(rèn)信號(hào)。

在主循環(huán)中，我們從該隊(duì)列讀取，并計(jì)數(shù)-1。 一旦我們計(jì)算了我們有過程的終止確認(rèn)數(shù)量，主循環(huán)就會(huì)退出。 否則，我們從隊(duì)列中輸出計(jì)算結(jié)果。

清單2.7：結(jié)果的終止和輸出

?

示例2顯示了Python程序的輸出。 運(yùn)行程序不止一次，您可能會(huì)注意到，工作進(jìn)程啟動(dòng)的順序與從隊(duì)列中選擇任務(wù)的進(jìn)程本身不可預(yù)測(cè)。 但是，一旦完成結(jié)果隊(duì)列的元素的順序與任務(wù)隊(duì)列的元素的順序相匹配。

示例2

注意：如前所述，由于執(zhí)行順序不可預(yù)測(cè)，您的輸出可能與上面顯示的輸出不一致。

?

使用os.system()方法