成人午夜视频全免费观看高清-秋霞福利视频一区二区三区-国产精品久久久久电影小说-亚洲不卡区三一区三区一区

如何在Python3中使用進程池和回調(diào)函數(shù)-創(chuàng)新互聯(lián)

這篇文章給大家介紹如何在Python3中使用進程池和回調(diào)函數(shù),內(nèi)容非常詳細,感興趣的小伙伴們可以參考借鑒,希望對大家能有所幫助。

石景山ssl適用于網(wǎng)站、小程序/APP、API接口等需要進行數(shù)據(jù)傳輸應(yīng)用場景,ssl證書未來市場廣闊!成為創(chuàng)新互聯(lián)建站的ssl證書銷售渠道,可以享受市場價格4-6折優(yōu)惠!如果有意向歡迎電話聯(lián)系或者加微信:18980820575(備注:SSL證書合作)期待與您的合作!

方式一

from multiprocessing import Pool


def deal_task(n):
 n -= 1
 return n


if __name__ == '__main__':
 n = 10
 p = Pool(4)
 for i in range(4):
  res = p.apply(deal_task, args=(n,))
  #調(diào)用apply是一個串行的效果,任務(wù)會被進程一個一個的處理,直接得到結(jié)果
  #前提是執(zhí)行的任務(wù)必須要有返回值
  print(res)

方式二

from multiprocessing import Pool


def deal_task(n):
 n -= 1
 return n


if __name__ == '__main__':
 n = 10
 p = Pool(4)
 obj_l = []
 for i in range(4):
  #調(diào)用apply_async會返回一個對象,主進程會不斷扔任務(wù)給線程池,讓子線程處理
  obj = p.apply_async(deal_task, args=(n,))
  obj_l.append(obj)
 #首先函數(shù)要有返回值
 #調(diào)用close目的是防止join期間會有別的任務(wù)被添加到任務(wù)列表中
 #不調(diào)用close會報錯
 p.close()
 p.join()
 #join是要讓子進程全部處理完之后得到結(jié)果統(tǒng)一處理,還有一個非常重要的原因是進程池依附于主進程,主進程結(jié)束,進程池消失。進程池的任務(wù)沒有被處理程序就結(jié)束了。
 for obj in obj_l:
  print(obj.get())

方式三

from multiprocessing import Pool

import requests


def get_page(url):
 ret = requests.get(url).text
 return {'url': url, 'ret': ret}


def parse_page(ret):
 with open('ab.txt', 'a') as f:
  f.write('%s - %s\n' % (ret['url'], len(ret['ret'])))


if __name__ == '__main__':
 urls = [
  'https://www.baidu.com',
  'http://www.openstack.org',
  'https://www.python.org',
  'https://help.github.com/',
  'http://www.sina.com.cn/'
 ]
 p = Pool()
 for url in urls:
  #使用回調(diào)函數(shù),當get_page下載完后,主線程調(diào)用parse_page自動處理get_page下載的結(jié)果,節(jié)省了parse_page的時間,該場景用于一個函數(shù)為耗時操作并且產(chǎn)生數(shù)據(jù),另一個函數(shù)是非耗時操作,這樣就節(jié)省了非耗時操作函數(shù)的時間
  p.apply_async(get_page, args=(url,), callback=parse_page)

 p.close()
 p.join()
 print('主')

join是要讓子進程全部處理完之后得到結(jié)果統(tǒng)一處理,還有一個非常重要的原因是進程池依附于主進程,主進程結(jié)束,進程池消失。進程池的任務(wù)沒有被處理程序就結(jié)束了。

關(guān)于如何在Python3中使用進程池和回調(diào)函數(shù)就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。

網(wǎng)頁題目:如何在Python3中使用進程池和回調(diào)函數(shù)-創(chuàng)新互聯(lián)
當前鏈接:http://jinyejixie.com/article48/csoeep.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供移動網(wǎng)站建設(shè)、虛擬主機、云服務(wù)器、建站公司、企業(yè)建站手機網(wǎng)站建設(shè)

廣告

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

微信小程序開發(fā)
蓝田县| 宁城县| 习水县| 长汀县| 原阳县| 武胜县| 通道| 噶尔县| 昌宁县| 闻喜县| 康保县| 齐齐哈尔市| 沾益县| 恩施市| 和龙市| 囊谦县| 宝丰县| 乐亭县| 渝中区| 宁阳县| 阿合奇县| 安宁市| 精河县| 浦城县| 安岳县| 沽源县| 修水县| 宜州市| 昌吉市| 夏河县| 乐都县| 宝兴县| 乃东县| 壤塘县| 开平市| 赤壁市| 新乡县| 荆州市| 诸城市| 通州市| 和静县|