在新創建的子進程中，會把父進程的所有信息複製一份，它們之間的數據互不影響。 ### 1.使用os.fork()創建 該方式只能用於Unix/Linux操作系統中，在windows不能用。 ```python import os # 註意，fork函數，只在Unix/Linux/Mac上運行，wind ...
在新創建的子進程中，會把父進程的所有信息複製一份，它們之間的數據互不影響。
1.使用os.fork()創建
該方式只能用於Unix/Linux操作系統中，在windows不能用。
import os
# 註意，fork函數，只在Unix/Linux/Mac上運行，windows不可以
pid = os.fork()
# 子進程永遠返回0，而父進程返回子進程的ID。
if pid == 0:
print('子進程')
else:
print('父進程')
2.使用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
子進程結束
"""
3.使用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__()
# 學習中遇到問題沒人解答？小編創建了一個Python學習交流群：711312441
# 重寫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)
4.使用進程池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() # 進程池後面無操作時必須有這句
