在新創(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ì)您有幫助就好】元
