快捷導(dǎo)航

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

更新時間：2019年08月29日 09:16:51 作者：三國小夢

這篇文章主要介紹了python 進(jìn)程的幾種創(chuàng)建方式詳解,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下

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

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

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

import os
# 注意，fork函數(shù)，只在Unix/Linux/Mac上運行，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模塊提供了一個Process類來代表一個進(jìn)程對象，下面的例子演示了啟動一個子進(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)程實例執(zhí)⾏結(jié)束，或等待多少秒；
  p.join() # 等待的最長時間
  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)程還能夠使用類的方式，可以自定義一個類，繼承Process類，每次實例化這個類的時候，就等同于實例化一個進(jìn)程對象，請看下面的實例：

from multiprocessing import Process
import time
import os
class MyProcess(Process):
  def __init__(self):
    # 如果子類要重寫__init__是必須要先調(diào)用父類的__init__否則會報錯
    # 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)需要創(chuàng)建的子進(jìn)程數(shù)量不多時，可以直接利用multiprocessing中的Process動態(tài)成生多個進(jìn)程，但如果是上百甚至上千個目標(biāo)，手動的去創(chuàng)建進(jìn)程的工作量巨大，此時就可以用到multiprocessing模塊提供的Pool方法。

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

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

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

您可能感興趣的文章: