亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

python 進(jìn)程的幾種創(chuàng)建方式詳解

系統(tǒng) 1751 0

在新創(chuàng)建的子進(jìn)程中,會(huì)把父進(jìn)程的所有信息復(fù)制一份,它們之間的數(shù)據(jù)互不影響。

使用os.fork()創(chuàng)建

該方式只能用于Unix/Linux操作系統(tǒng)中,在windows不能用。

            
import os
# 注意,fork函數(shù),只在Unix/Linux/Mac上運(yùn)行,windows不可以
pid = os.fork()
# 子進(jìn)程永遠(yuǎn)返回0,而父進(jìn)程返回子進(jìn)程的ID。
if pid == 0:
  print('子進(jìn)程')
else:
  print('父進(jìn)程')
          

使用Process類類創(chuàng)建

multiprocessing模塊提供了一個(gè)Process類來代表一個(gè)進(jìn)程對(duì)象,下面的例子演示了啟動(dòng)一個(gè)子進(jìn)程并等待其結(jié)束:

            
from multiprocessing import Process
import time

def test(name, age):
  for i in range(5):
    print("--test--%s\t%d" % (name, age))
    time.sleep(1)
  print("子進(jìn)程結(jié)束")
if __name__ == '__main__':
  p = Process(target=test, args=("aaa", 18))
  p.start()
  # 等待進(jìn)程實(shí)例執(zhí)?結(jié)束,或等待多少秒;
  p.join() # 等待的最長(zhǎng)時(shí)間
  print("主進(jìn)程結(jié)束")
"""
輸出結(jié)果:
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
子進(jìn)程結(jié)束
主進(jìn)程結(jié)束
"""
          

join()方法表示主進(jìn)程等待子進(jìn)程執(zhí)行完成后繼續(xù)往下執(zhí)行,如果把join()注釋掉,則主進(jìn)程開啟子進(jìn)程后不停頓繼續(xù)往下執(zhí)行,然后等待子進(jìn)程完成程序結(jié)束。

把join()方法注釋掉的結(jié)果:

            
"""
輸出結(jié)果:
主進(jìn)程結(jié)束
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
子進(jìn)程結(jié)束
"""
          

使用Process子類創(chuàng)建

創(chuàng)建新的進(jìn)程還能夠使用類的方式,可以自定義一個(gè)類,繼承Process類,每次實(shí)例化這個(gè)類的時(shí)候,就等同于實(shí)例化一個(gè)進(jìn)程對(duì)象,請(qǐng)看下面的實(shí)例:

            
from multiprocessing import Process
import time
import os
class MyProcess(Process):
  def __init__(self):
    # 如果子類要重寫__init__是必須要先調(diào)用父類的__init__否則會(huì)報(bào)錯(cuò)
    # Process.__init__(self)  
    super(MyProcess,self).__init__()
  # 重寫Porcess的run()方法
  def run(self):
    print("子進(jìn)程(%s)開始執(zhí)行,父進(jìn)程(%s)" % (os.getpid(), os.getppid()))
    for i in range(5):
      print("--1--")
      time.sleep(1)
if __name__ == '__main__':
  t_start = time.time()
  p = MyProcess()
  p.start()
  # p.join()
  print("main")
  for i in range(5):
    print("--main--")
    time.sleep(1)
          

使用進(jìn)程池Pool創(chuàng)建

當(dāng)需要?jiǎng)?chuàng)建的子進(jìn)程數(shù)量不多時(shí),可以直接利用multiprocessing中的Process動(dòng)態(tài)成生多個(gè)進(jìn)程,但如果是上百甚至上千個(gè)目標(biāo),手動(dòng)的去創(chuàng)建進(jìn)程的工作量巨大,此時(shí)就可以用到multiprocessing模塊提供的Pool方法。

初始化Pool時(shí),可以指定一個(gè)最大進(jìn)程數(shù),當(dāng)有新的請(qǐng)求提交到Pool中時(shí),如果池還沒有滿,那么就會(huì)創(chuàng)建一個(gè)新的進(jìn)程用來執(zhí)行該請(qǐng)求;但如果池中的進(jìn)程數(shù)已經(jīng)達(dá)到指定的最大值,那么該請(qǐng)求就會(huì)等待,直到池中有進(jìn)程結(jié)束,才會(huì)創(chuàng)建新的進(jìn)程來執(zhí)行,請(qǐng)看下面的實(shí)例:

            
from multiprocessing import Pool
import os
import time


def worker(num):
  # for i in range(3):
  print("----pid=%d num=%d---" % (os.getpid(), num))
  time.sleep(1)

if __name__ == '__main__':
  # 定義一個(gè)進(jìn)程池,最大進(jìn)程數(shù)3
  pool = Pool(3)
  for i in range(10):
    print("---%d--" % i)
    # 使用非阻塞方式調(diào)用func(并行執(zhí)行),一般用這個(gè)。
    # apply堵塞方式必須等待上一個(gè)進(jìn)程退出才能執(zhí)行下一個(gè)進(jìn)程,用的不多。
    pool.apply_async(worker, (i,))
  # 關(guān)閉進(jìn)程池
  pool.close()
  # 等待所有子進(jìn)程結(jié)束,主進(jìn)程一般用來等待
  pool.join() # 進(jìn)程池后面無操作時(shí)必須有這句
          

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號(hào)聯(lián)系: 360901061

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長(zhǎng)非常感激您!手機(jī)微信長(zhǎng)按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對(duì)您有幫助就好】

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺我的文章對(duì)您有幫助,請(qǐng)用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長(zhǎng)會(huì)非常 感謝您的哦!!!

發(fā)表我的評(píng)論
最新評(píng)論 總共0條評(píng)論
主站蜘蛛池模板: 欧美激情日本一道免费视频 | 亚洲精品欧美精品一区二区 | 亚洲码欧美码一区二区三区 | 特级毛片免费视频播放 | 日本二三区 | 日韩不卡在线观看 | 美女网站视频免费 | 综合久久久久久久 | 国产精品久久久久久久免费 | 久草在线中文最新视频 | 国产精品国产三级国产普通话 | 成人影院在线观看kkk4444 | 亚洲v欧美 | 一区二区三区在线视频观看 | 九九热亚洲精品综合视频 | 国产成人亚洲精品老王 | 婷婷六月综合网 | 天天做天天添婷婷我也去 | 韩国午夜影院 | 狠狠综合久久 | 国产三级久久久精品三级 | 精品国产一区二区 | 日本狠狠操| 伊人一区二区三区 | 真实偷清晰对白在线视频 | 免费爱爱的视频太爽了 | 日韩第3页 | 国产成人乱码一区二区三区在线 | 国产娱乐凹凸视觉盛宴在线视频 | 亚洲国产综合专区在线播一一 | 国产精品久久久久久麻豆一区 | 国产在线观看精品香蕉v区 国产在线观看美女福利精 国产在线观看午夜不卡 | 欧美精品中文字幕手机免费视频 | 国产一区二区在线视频观看 | 九九视频网 | 国产国产人免费人成成免视频 | 91青青青国产在观免费影视 | 成人午夜亚洲影视在线观看 | 久久色伊人 | 欧美乱人免费视频观看 | 亚洲日本中文字幕在线2022 |