快捷導(dǎo)航

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

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

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

在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)象。

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