python中的多進(jìn)程的創(chuàng)建與啟動(dòng)方式

更新時(shí)間：2022年12月01日 16:49:31 作者：小樹苗m

這篇文章主要介紹了python中的多進(jìn)程的創(chuàng)建與啟動(dòng),python中的并發(fā)有三種形式，多進(jìn)程、多線程、協(xié)程，執(zhí)?并發(fā)任務(wù)的?的是為了提?程序運(yùn)?的效率，本文通過實(shí)例代碼詳細(xì)講解需要的朋友可以參考下

一、多進(jìn)程的創(chuàng)建：多進(jìn)程的創(chuàng)建方法有兩種：

1、通過Process創(chuàng)建多進(jìn)程 Process語法結(jié)構(gòu)：

			Process(group, target, name, args, kwargs)
			group：指定進(jìn)程組，?多數(shù)情況下?不到
			target：表示調(diào)用對(duì)象，即子進(jìn)程要執(zhí)行的任務(wù)
			name：子進(jìn)程的名稱，可以不設(shè)定
			args：給target指定的函數(shù)傳遞的參數(shù)，以元組的?式傳遞
			kwargs：給target指定的函數(shù)傳遞命名參數(shù)

Process常用方法：

			p.start() 啟動(dòng)進(jìn)程，并調(diào)用該子進(jìn)程中的p.run()方法
			p.join(timeout):主進(jìn)程等待?進(jìn)程執(zhí)?結(jié)束再結(jié)束，timeout是可選的超時(shí)時(shí)間
			is_alive()：判斷進(jìn)程?進(jìn)程是否還存活
			p.run() 進(jìn)程啟動(dòng)時(shí)運(yùn)行的方法，正是它去調(diào)用target指定的函數(shù)
			p.terminate() ?即終??進(jìn)程

（1）首先，定義一個(gè)待調(diào)用的函數(shù)：

import os
from multiprocessing import Process
def add(name,num):
    nums = 0
    for i in range(num+1):
        nums = nums+i
    print("用戶%s:\n  相加結(jié)果為:%s \n  當(dāng)前進(jìn)程id為：%s \n  當(dāng)前子進(jìn)程的父進(jìn)程id： %s"%(name,nums,os.getpid(),os.getppid()))

（2）創(chuàng)建并啟動(dòng)一個(gè)進(jìn)程

def test1():
    '''啟動(dòng)一個(gè)進(jìn)程調(diào)用'''
    name= '王五'
    p = Process(target=add,args=(name,10,))
    p.start()
    p.join()

其中，p.join()方法可以讓主進(jìn)程等待子進(jìn)程結(jié)束之后再結(jié)束，如果不加這個(gè)方法，主進(jìn)程結(jié)束，子進(jìn)程還沒有結(jié)束。
(2)創(chuàng)建并啟動(dòng)多個(gè)進(jìn)程

def test3():
    names = ['王五','趙六','王麻子']
    process_list=[]
    for name in names:
        p = Process(target=add,args=(name,10,))
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()

2、通過進(jìn)程池創(chuàng)建并啟動(dòng)多進(jìn)程

進(jìn)程池可以提供指定數(shù)量的進(jìn)程給用戶使用,即當(dāng)有新的請(qǐng)求提交到進(jìn)程池中時(shí)，如果池未滿，則會(huì)創(chuàng)建一個(gè)新的進(jìn)程用來執(zhí)行該請(qǐng)求;反之，如果池中的進(jìn)程數(shù)已經(jīng)達(dá)到規(guī)定最大值，那么該請(qǐng)求就會(huì)等待，只要池中有進(jìn)程空閑下來，該請(qǐng)求就能得到執(zhí)行。
Pool（numprocess, initializer, initargs）
numprocess 是要?jiǎng)?chuàng)建的進(jìn)程數(shù)。如果省略此參數(shù)，默認(rèn)為cpu的最大核心數(shù)。
Initializer是每個(gè)工作進(jìn)程啟動(dòng)時(shí)要執(zhí)行的可調(diào)用對(duì)象。
Initargs 傳遞給 initializer 的參數(shù)元祖，默認(rèn)為 None

def test4():
    from multiprocessing import Pool
    '''啟動(dòng)多個(gè)進(jìn)程2:進(jìn)程池'''
    p = Pool(5)
    names = ['王五','趙六','王麻子']
    for name in names:
        p.apply_async(add,args=(name,10))
    p.close()
    p.join()

3、通過繼承的方法創(chuàng)建多進(jìn)程

（1）首先創(chuàng)建一個(gè)進(jìn)程

class SubProcess(Process):
    def __init__(self,name,number):
        super(SubProcess, self).__init__()
        self.name = name
        self.number = number
    def run(self):
        sums = 0
        for i in range(self.number):
            sums = sums+i
        print("用戶%s:\n  相加結(jié)果為:%s \n  當(dāng)前進(jìn)程id為：%s \n  當(dāng)前子進(jìn)程的父進(jìn)程id： %s"\
              %(self.name,self.number,os.getpid(),os.getppid()))

（2）啟動(dòng)一個(gè)進(jìn)程

def call_Sub0():
    '''啟動(dòng)一個(gè)進(jìn)程調(diào)用'''
    name = '張三'
    p = SubProcess(name,10)
    p.start()
    p.join()

（3）通過列表啟動(dòng)多個(gè)進(jìn)程

def call_Sub1():
    '''啟動(dòng)多個(gè)進(jìn)程1'''
    names = ['王五','趙六','王麻子']
    process_list=[]
    for name in names:
        p = SubProcess(name,10)
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()
 if __name__ == '__main__':
    print("當(dāng)前主進(jìn)程id:",os.getpid())
    call_Sub1()
    print("計(jì)算結(jié)束！")

4、進(jìn)程創(chuàng)建與啟動(dòng)完整代碼

import os
from multiprocessing import Process
def add(name,num):
    nums = 0
    for i in range(num+1):
        nums = nums+i
    print("用戶%s:\n  相加結(jié)果為:%s \n  當(dāng)前進(jìn)程id為：%s \n  當(dāng)前子進(jìn)程的父進(jìn)程id： %s"%(name,nums,os.getpid(),os.getppid()))
def test1():
    '''啟動(dòng)一個(gè)進(jìn)程調(diào)用'''
    name= '王五'
    p = Process(target=add,args=(name,10,))
    p.start()
    p.join()
def test3():
    '''啟動(dòng)多個(gè)進(jìn)程2'''
    names = ['王五','趙六','王麻子']
    process_list=[]
    for name in names:
        p = Process(target=add,args=(name,10,))
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()
'''
進(jìn)程池：可以提供指定數(shù)量的進(jìn)程給用戶使用,即當(dāng)有新的請(qǐng)求提交到進(jìn)程池中時(shí)，
如果池未滿，則會(huì)創(chuàng)建一個(gè)新的進(jìn)程用來執(zhí)行該請(qǐng)求;反之，如果池中的進(jìn)程數(shù)已經(jīng)達(dá)到規(guī)定最大值，
那么該請(qǐng)求就會(huì)等待，只要池中有進(jìn)程空閑下來，該請(qǐng)求就能得到執(zhí)行。
'''
def test4():
    from multiprocessing import Pool
    '''啟動(dòng)多個(gè)進(jìn)程2:進(jìn)程池'''
    p = Pool(5)
    names = ['王五','趙六','王麻子']
    for name in names:
        p.apply_async(add,args=(name,10))
    p.close()
    p.join()

class SubProcess(Process):
    def __init__(self,name,number):
        super(SubProcess, self).__init__()
        self.name = name
        self.number = number
    def run(self):
        sums = 0
        for i in range(self.number):
            sums = sums+i
        print("用戶%s:\n  相加結(jié)果為:%s \n  當(dāng)前進(jìn)程id為：%s \n  當(dāng)前子進(jìn)程的父進(jìn)程id： %s"\
              %(self.name,self.number,os.getpid(),os.getppid()))
def call_Sub0():
    '''啟動(dòng)一個(gè)進(jìn)程調(diào)用'''
    name = '張三'
    p = SubProcess(name,10)
    p.start()
    p.join()
def call_Sub1():
    '''啟動(dòng)多個(gè)進(jìn)程1'''
    names = ['王五','趙六','王麻子']
    process_list=[]
    for name in names:
        p = SubProcess(name,10)
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()

if __name__ == '__main__':
    print("當(dāng)前主進(jìn)程id:",os.getpid())
    call_Sub1()
    print("計(jì)算結(jié)束！")

到此這篇關(guān)于python中的多進(jìn)程的創(chuàng)建與啟動(dòng)的文章就介紹到這了,更多相關(guān)python多進(jìn)程創(chuàng)建與啟動(dòng)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: