對Python中創(chuàng)建進程的兩種方式以及進程池詳解

更新時間：2019年01月14日 09:12:49 作者：KUNLI7

今天小編就為大家分享一篇對Python中創(chuàng)建進程的兩種方式以及進程池詳解，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

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

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)建一個進程對象，然后p.start()即可開啟進程，test函數(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)建進程的方式，通過子類繼承Process類，子類中必須有run方法，里面實現(xiàn)進程功能，創(chuàng)建子類對象之后，調(diào)用對象的start方法。

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

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

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

以上這篇對Python中創(chuàng)建進程的兩種方式以及進程池詳解就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。