国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

python之multiprocessing.pool

2019-11-06 07:19:52
字體:
來源:轉載
供稿:網友

Pool相關函數

1、apply(func[, args[, kwds]]) apply用于傳遞不定參數,同python中的apply函數一致(不過內置的apply函數從2.3以后就不建議使用了),主進程會阻塞于函數。

主進程的執行流程同單進程一致。

2、apply_async(func[, args[, kwds[, callback]]]) 與apply用法一致,但它是非阻塞的且支持結果返回后進行回調。

主進程循環運行過程中不等待apply_async的返回結果,在主進程結束后,即使子進程還未返回整個程序也會退出。雖然 apply_async是非阻塞的,但其返回結果的get方法卻是阻塞的,如使用result.get()會阻塞主進程。 如果我們對返回結果不感興趣, 那么可以在主進程中使用pool.close與pool.join來防止主進程退出。注意join方法一定要在close或terminate之后調用。

3、map(func, iterable[, chunksize]) map方法與在功能上等價與內置的map(),只不過單個任務會并行運行。它會使進程阻塞直到結果返回。 但需注意的是其第二個參數雖然描述的為iterable, 但在實際使用中發現只有在整個隊列全部就緒后,程序才會運行子進程。

4、map_async(func, iterable[, chunksize[, callback]]) 與map用法一致,但是它是非阻塞的。其有關事項見apply_async。

5、imap(func, iterable[, chunksize]) 與map不同的是, imap的返回結果為iter,需要在主進程中主動使用next來驅動子進程的調用。即使子進程沒有返回結果,主進程對于gen_list(l)的 iter還是會繼續進行, 另外根據python2.6文檔的描述,對于大數據量的iterable而言,將chunksize設置大一些比默認的1要好。

for x in pool.imap(pool_test, gen_list(l)): pass

6、imap_unordered(func, iterable[, chunksize]) 同imap一致,只不過其并不保證返回結果與迭代傳入的順序一致。

7、close() 關閉pool,使其不再接受新的任務。

8、terminate() 結束工作進程,不再處理未處理的任務。

9、join() 主進程阻塞等待子進程的退出, join方法要在close或terminate之后使用。


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 南郑县| 石柱| 鄄城县| 东至县| 金塔县| 安庆市| 新密市| 唐山市| 浠水县| 石屏县| 阳城县| 湖州市| 会昌县| 孟连| 文安县| 罗平县| 彝良县| 洛宁县| 右玉县| 云梦县| 巴林右旗| 白山市| 米易县| 临猗县| 巴中市| 保定市| 兰坪| 嘉定区| 海城市| 唐海县| 历史| 彝良县| 晋江市| 吴江市| 南郑县| 广丰县| 江陵县| 广南县| 凯里市| 沙田区| 克什克腾旗|