在新創建的子進程中，會把父進程的所有信息復制一份，它們之間的數據互不影響。
使用os.fork()創建
該方式只能用于Unix/Linux操作系統中，在windows不能用。
import os
# 注意，fork函數，只在Unix/Linux/Mac上運行，windows不可以
pid = os.fork()
# 子進程永遠返回0，而父進程返回子進程的ID。
if pid == 0:
print('子進程')
else:
print('父進程')
使用Process類類創建
multiprocessing模塊提供了一個Process類來代表一個進程對象，下面的例子演示了啟動一個子進程并等待其結束：
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("子進程結束")
if __name__ == '__main__':
p = Process(target=test, args=("aaa", 18))
p.start()
# 等待進程實例執?結束，或等待多少秒；
p.join() # 等待的最長時間
print("主進程結束")
"""
輸出結果：
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
子進程結束
主進程結束
"""
join()方法表示主進程等待子進程執行完成后繼續往下執行，如果把join()注釋掉，則主進程開啟子進程后不停頓繼續往下執行，然后等待子進程完成程序結束。
把join()方法注釋掉的結果：
"""
輸出結果：
主進程結束
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
--test--aaa 18
子進程結束
"""
使用Process子類創建
創建新的進程還能夠使用類的方式，可以自定義一個類，繼承Process類，每次實例化這個類的時候，就等同于實例化一個進程對象，請看下面的實例：
from multiprocessing import Process
import time
import os
class MyProcess(Process):
def __init__(self):
# 如果子類要重寫__init__是必須要先調用父類的__init__否則會報錯
# Process.__init__(self)
super(MyProcess,self).__init__()
# 重寫Porcess的run()方法
def run(self):
print("子進程(%s)開始執行，父進程(%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)
使用進程池Pool創建
當需要創建的子進程數量不多時，可以直接利用multiprocessing中的Process動態成生多個進程，但如果是上百甚至上千個目標，手動的去創建進程的工作量巨大，此時就可以用到multiprocessing模塊提供的Pool方法。
初始化Pool時，可以指定一個最大進程數，當有新的請求提交到Pool中時，如果池還沒有滿，那么就會創建一個新的進程用來執行該請求；但如果池中的進程數已經達到指定的最大值，那么該請求就會等待，直到池中有進程結束，才會創建新的進程來執行，請看下面的實例：
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__':
# 定義一個進程池，最大進程數3
pool = Pool(3)
for i in range(10):
print("---%d--" % i)
# 使用非阻塞方式調用func（并行執行)，一般用這個。
# apply堵塞方式必須等待上一個進程退出才能執行下一個進程,用的不多。
pool.apply_async(worker, (i,))
# 關閉進程池
pool.close()
# 等待所有子進程結束，主進程一般用來等待
pool.join() # 進程池后面無操作時必須有這句
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
