對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()
 # 調用p.start()方法，p會先去父類中尋找start()，然后在Process的start方法中調用run方法
 p.start()
 
 while True:
  print('---Main---')
  time.sleep(1)

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

下面來說一下進程池，就是實現(xiàn)已經創(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í)行的話，他會等待前面的進程結束，然后在往
 # 進程池中添加新進程
 pool.apply_async(worker,(i,))
 
pool.close() # 關閉進程池
pool.join() # 主進程在這里等待，只有子進程全部結束之后，在會開啟主線程

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

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