知識(shí)點(diǎn)1進(jìn)程池

進(jìn)程池（Pool）進(jìn)程池（Pool）摘要：開(kāi)多進(jìn)程的目的是為了并發(fā)，如果有多核，通常有幾個(gè)核就開(kāi)幾個(gè)進(jìn)程，進(jìn)程開(kāi)啟過(guò)多，效率反而會(huì)下降（開(kāi)啟進(jìn)程是需要占用系統(tǒng)資源的，而且開(kāi)啟多余核數(shù)目的進(jìn)程也無(wú)法做到并行），但很明顯需要并發(fā)執(zhí)行的任務(wù)要遠(yuǎn)大于核數(shù)，這時(shí)可以通過(guò)維護(hù)一個(gè)進(jìn)程池來(lái)控制進(jìn)程數(shù)目。Pool可以提供指定數(shù)量的進(jìn)程，供用戶調(diào)用，當(dāng)有新的請(qǐng)求提交到pool中時(shí)，如果池還沒(méi)有滿，那么就會(huì)創(chuàng)建一個(gè)新的進(jìn)程用來(lái)執(zhí)行該請(qǐng)求；但如果池中的進(jìn)程數(shù)已經(jīng)達(dá)到規(guī)定最大值，那么該請(qǐng)求就會(huì)等待，直到池中有進(jìn)程結(jié)束，就重用進(jìn)程池中的進(jìn)程。關(guān)鍵詞Pool12·創(chuàng)建進(jìn)程池的類(lèi)Pool([numprocess[,initializer[,initargs]]]):創(chuàng)建進(jìn)程池·參數(shù)介紹：1.numprocess:要?jiǎng)?chuàng)建的進(jìn)程數(shù)，如果省略，將默認(rèn)使用cpu_count()的值2.initializer：是每個(gè)工作進(jìn)程啟動(dòng)時(shí)要執(zhí)行的可調(diào)用對(duì)象，默認(rèn)為None3.initargs：是要傳給initializer的參數(shù)組進(jìn)程池（Pool）方法介紹：p是Pool類(lèi)的一個(gè)實(shí)例p.apply(func[,args[,kwargs]]):在一個(gè)池工作進(jìn)程中執(zhí)行func(*args,**kwargs),然后返回結(jié)果。需要強(qiáng)調(diào)的是：此操作并不會(huì)在所有池工作進(jìn)程中并執(zhí)行func函數(shù)。如果要通過(guò)不同參數(shù)并發(fā)地執(zhí)行func函數(shù)，必須從不同線程調(diào)用p.apply()函數(shù)或者使用p.apply_async()p.apply_async(func[,args[,kwargs]]，callback=None):在一個(gè)池工作進(jìn)程中執(zhí)行func(*args,**kwargs),然后返回結(jié)果。callback是可調(diào)用對(duì)象，接收輸入?yún)?shù)。當(dāng)func的結(jié)果變?yōu)榭捎脮r(shí)，將理解傳遞給callback。callback禁止執(zhí)行任何阻塞操作，否則將接收其他異步操作中的結(jié)果。p.close():關(guān)閉進(jìn)程池，防止進(jìn)一步操作。如果所有操作持續(xù)掛起，它們將在工作進(jìn)程終止前完成P.jion():等待所有工作進(jìn)程退出。此方法只能在close（）或teminate()之后調(diào)用34示例1：apply同步執(zhí)行：阻