溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
在新創建的子進程中，會把父進程的所有信息復制一份，它們之間的數據互不影響。
使用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() # 進程池后面無操作時必須有這句
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
