如何在Python中創(chuàng)建進(jìn)程

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

在Python中創(chuàng)建進(jìn)程有兩種方式，第一種是：

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類可以創(chuàng)建一個進(jìn)程對象，然后p.start()即可開啟進(jìn)程，test函數(shù)是你想進(jìn)程實(shí)現(xiàn)的功能。

第二種方式是：

from multiprocessing import Process
import time
 
class MyNewProcess(Process):
 def run(self):
  while True:
   print('---1---')
   time.sleep(1)
 
if __name__=='__mian__':
 p = MyNewProcess()
 # 調(diào)用p.start()方法，p會先去父類中尋找start()，然后在Process的start方法中調(diào)用run方法
 p.start()
 
 while True:
  print('---Main---')
  time.sleep(1)

這里是第二種創(chuàng)建進(jìn)程的方式，通過子類繼承Process類，子類中必須有run方法，里面實(shí)現(xiàn)進(jìn)程功能，創(chuàng)建子類對象之后，調(diào)用對象的start方法。

下面來說一下進(jìn)程池，就是實(shí)現(xiàn)已經(jīng)創(chuàng)建好的進(jìn)程

# 進(jìn)程池
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表示進(jìn)程池中最多有三個進(jìn)程一起執(zhí)行
pool=Pool(3)
 
for i in range(10):
 print('---%d---'%i)
 # 向進(jìn)程中添加任務(wù)
 # 注意：如果添加的任務(wù)數(shù)量超過了進(jìn)程池中進(jìn)程的個數(shù)的話，那么就不會接著往進(jìn)程池中添加，如果還沒有執(zhí)行的話，他會等待前面的進(jìn)程結(jié)束，然后在往
 # 進(jìn)程池中添加新進(jìn)程
 pool.apply_async(worker,(i,))
 
pool.close() # 關(guān)閉進(jìn)程池
pool.join() # 主進(jìn)程在這里等待，只有子進(jìn)程全部結(jié)束之后，在會開啟主線程

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

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“如何在Python中創(chuàng)建進(jìn)程”這篇文章對大家有幫助，同時(shí)也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識等著你來學(xué)習(xí)!