在Python中創(chuàng)建進程有兩種方式，第一種是：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
from multiprocessing import Processimport time def test(): while True: print('---test---') time.sleep(1) if __name__ == '__main__': p=Process(target=test) p.start() while True: print('---main---') time.sleep(1) |
上面這段代碼是在windows下跑的，通過Process類可以創(chuàng)建一個進程對象，然后p.start()即可開啟進程，test函數是你想進程實現的功能。
第二種方式是：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
from multiprocessing import Processimport time class MyNewProcess(Process): def run(self): while True: print('---1---') time.sleep(1) if __name__=='__mian__': p = MyNewProcess() # 調用p.start()方法，p會先去父類中尋找start()，然后在Process的start方法中調用run方法 p.start() while True: print('---Main---') time.sleep(1) |
這里是第二種創(chuàng)建進程的方式，通過子類繼承Process類，子類中必須有run方法，里面實現進程功能，創(chuàng)建子類對象之后，調用對象的start方法。
下面來說一下進程池，就是實現已經創(chuàng)建好的進程
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# 進程池from multiprocessing import Poolimport osimport randomimport time def worker(num): for i in range(5): print('===pid=%d==num=%d='%(os.getpid(),num)) time.sleep(1) # 3表示進程池中最多有三個進程一起執(zhí)行pool=Pool(3) for i in range(10): print('---%d---'%i) # 向進程中添加任務 # 注意：如果添加的任務數量超過了進程池中進程的個數的話，那么就不會接著往進程池中添加，如果還沒有執(zhí)行的話，他會等待前面的進程結束，然后在往 # 進程池中添加新進程 pool.apply_async(worker,(i,)) pool.close() # 關閉進程池pool.join() # 主進程在這里等待，只有子進程全部結束之后，在會開啟主線程 |
大家可以看到在Pool方法就是創(chuàng)建了一個進程池，3表示創(chuàng)建進程數，通過pool.apply_async( )將子進程添加到進程池中，pool.close( )表示關閉進程池，一定要添加join函數，否則主進程直接崩了，看不到進程池中子進程的現象。
以上這篇對Python中創(chuàng)建進程的兩種方式以及進程池詳解就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/u012193416/article/details/78396814
