如何在Python中創建進程

這篇文章主要介紹了如何在Python中創建進程，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

在Python中創建進程有兩種方式，第一種是：

from multiprocessing import Process
import 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類可以創建一個進程對象，然后p.start()即可開啟進程，test函數是你想進程實現的功能。

第二種方式是：

from multiprocessing import Process
import 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)

這里是第二種創建進程的方式，通過子類繼承Process類，子類中必須有run方法，里面實現進程功能，創建子類對象之后，調用對象的start方法。

下面來說一下進程池，就是實現已經創建好的進程

# 進程池
from multiprocessing import Pool
import os
import random
import time
 
def worker(num):
 for i in range(5):
  print('===pid=%d==num=%d='%(os.getpid(),num))
  time.sleep(1)
 
# 3表示進程池中最多有三個進程一起執行
pool=Pool(3)
 
for i in range(10):
 print('---%d---'%i)
 # 向進程中添加任務
 # 注意：如果添加的任務數量超過了進程池中進程的個數的話，那么就不會接著往進程池中添加，如果還沒有執行的話，他會等待前面的進程結束，然后在往
 # 進程池中添加新進程
 pool.apply_async(worker,(i,))
 
pool.close() # 關閉進程池
pool.join() # 主進程在這里等待，只有子進程全部結束之后，在會開啟主線程

大家可以看到在Pool方法就是創建了一個進程池，3表示創建進程數，通過pool.apply_async( )將子進程添加到進程池中，pool.close( )表示關閉進程池，一定要添加join函數，否則主進程直接崩了，看不到進程池中子進程的現象。

感謝你能夠認真閱讀完這篇文章，希望小編分享的“如何在Python中創建進程”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!