新聞中心

為汕尾等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù),及汕尾網(wǎng)站建設(shè)行業(yè)解決方案。主營(yíng)業(yè)務(wù)為網(wǎng)站建設(shè)、成都網(wǎng)站建設(shè)、汕尾網(wǎng)站設(shè)計(jì),以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求,就會(huì)得到認(rèn)可,從而選擇與我們長(zhǎng)期合作。這樣,我們也可以走得更遠(yuǎn)!
多進(jìn)程 multiprocessing
由于python是跨平臺(tái)的,自然也應(yīng)該提供一個(gè)跨平臺(tái)的多進(jìn)程支持。multiprocessing模塊就是跨平臺(tái)版本的多進(jìn)程模塊。
multiprocessing模塊提供了一個(gè)Process類來代表一個(gè)進(jìn)程對(duì)象。
Unix/Linux操作系統(tǒng)提供了一個(gè)fork()系統(tǒng)調(diào)用,它非常特殊。普通的函數(shù)調(diào)用,調(diào)用一次,返回一次,但是fork()調(diào)用一次,返回兩次,因?yàn)椴僮飨到y(tǒng)自動(dòng)把當(dāng)前進(jìn)程(稱為父進(jìn)程)復(fù)制了一份(稱為子進(jìn)程),然后,分別在父進(jìn)程和子進(jìn)程內(nèi)返回。
子進(jìn)程永遠(yuǎn)返回0,而父進(jìn)程返回子進(jìn)程的ID。這樣做的理由是,一個(gè)父進(jìn)程可以fork出很多子進(jìn)程,所以,父進(jìn)程要記下每個(gè)子進(jìn)程的ID,而子進(jìn)程只需要調(diào)用getppid()就可以拿到父進(jìn)程的ID。
Python的os模塊封裝了常見的系統(tǒng)調(diào)用,其中就包括fork,可以在Python程序中輕松創(chuàng)建子進(jìn)程:
import os
print('Process (%s) start...' % os.getpid())
# Only works on Unix/Linux/Mac:
pid = os.fork()
if pid == 0:
print('I am child process (%s) and my parent is %s.' % (os.getpid(), os.getppid()))
else:
print('I (%s) just created a child process (%s).' % (os.getpid(), pid))運(yùn)行結(jié)果如下:
Process (69673) start ... I (69673) just created a child Process(69674) I am child proces (69674) and my parent is 69673.
有了fork調(diào)用,一個(gè)進(jìn)程在接到新任務(wù)時(shí)就可以復(fù)制出一個(gè)子進(jìn)程來處理新任務(wù),常見的Apache服務(wù)器就是由父進(jìn)程監(jiān)聽端口,每當(dāng)有新的http請(qǐng)求時(shí),就fork出子進(jìn)程來處理新的http請(qǐng)求。
但是這個(gè)fork在windows操作系統(tǒng)是沒有的。于是出現(xiàn)了處理fork的通用模塊,以保證在不同操作系統(tǒng)間的調(diào)用。
multiprocessing模塊就是跨平臺(tái)版本的多進(jìn)程模塊。
multiprocessing模塊提供了一個(gè)Process類來代表一個(gè)進(jìn)程對(duì)象,下面的例子演示了啟動(dòng)一個(gè)子進(jìn)程并等待其結(jié)束:
#!/usr/bin/env python
# coding=utf-8
from multiprocessing import Process
import os
"""
子進(jìn)程要執(zhí)行的代碼
"""
def run_proc(name):
print('Run child process %s (%s)' % (name, os.getpid()))
if __name__ == '__main__':
print('Parent process %s.' % os.getpid())
p = Process(target=run_proc, args=('test_code',))
print('Child process will start.')
p.start()
p.join()
print('Child process end.')執(zhí)行結(jié)果如下:
$ python forkbymutilprocessing.py Parent process 70227. Child process will start. Run child process test_code (70228) Child process end.
創(chuàng)建子進(jìn)程時(shí),只需要傳入一個(gè)執(zhí)行函數(shù)和函數(shù)的參數(shù),創(chuàng)建一個(gè)Process實(shí)例,用start()方法啟動(dòng),這樣創(chuàng)建進(jìn)程比fork()還要簡(jiǎn)單。
join()方法可以等待子進(jìn)程結(jié)束后再繼續(xù)往下運(yùn)行,通常用于進(jìn)程間的同步。
當(dāng)前標(biāo)題:創(chuàng)新互聯(lián)Python教程:Python中的多進(jìn)程是什么
標(biāo)題路徑:http://www.dlmjj.cn/article/cddhesc.html


咨詢
建站咨詢
