1，os.fork() 方法

import os

ret = os.fork()

if ret == 0:

#子進(jìn)程

print("Sub process pid = %d, Sub process ppid = %d" % (os.getpid(), os.getppid()))

else:

#父進(jìn)程

print("Parent Process ret = %d" % ret)

print("Parent Process pid = %d" % os.getpid())

在該方法中，執(zhí)行os.fork()會(huì)再創(chuàng)建一個(gè)進(jìn)程，原進(jìn)程(父進(jìn)程)返回一個(gè)大于零的值(即ret > 0)，這個(gè)值恰好是子進(jìn)程的pid；而創(chuàng)建的新進(jìn)程會(huì)返回零(即ret = 0)。

fork炸彈：在用戶輸入欄輸入：

while True：

os.fork()

設(shè)備內(nèi)存就會(huì)很快被塞滿，然后down掉。

2，Process方法

from multiprocessing import Process

def func():

print("i am subprocess")

new_process = Process(tartget=func)

print("i am Parent Process")

Process方法需要指定一個(gè)函數(shù)，且父進(jìn)程會(huì)等待子進(jìn)程結(jié)束。另外可以新建一個(gè)example類繼承Process類，然后重寫__init__和run()函數(shù)，之后調(diào)用example.start()，它就會(huì)自動(dòng)執(zhí)行run()函數(shù)。

3，Pool方法

from multiprocessing import Pool

import time

def worker(x):

for j in range(1, 11):

print("%d:%d" % (x, j))

time.sleep(1)

pool = Pool(3) # run 3 process simultaneously

for i in range(1, 11):

print(i)

pool.apply_async(worker, (i,))

print("---start---")

pool.close() # 關(guān)閉進(jìn)程池，不允許繼續(xù)添加進(jìn)程

pool.join() # 等待進(jìn)程池中的所有進(jìn)程結(jié)束

print("---end---")

Pool方法即進(jìn)程池，需要說明有幾個(gè)進(jìn)程同時(shí)運(yùn)行。在使用apply_async方法時(shí)第一個(gè)參數(shù)是函數(shù)名，第二個(gè)參數(shù)需要輸入一個(gè)元組。在示例代碼中，進(jìn)程池同時(shí)允許三個(gè)進(jìn)程運(yùn)行，另外七個(gè)進(jìn)程排隊(duì)等候，當(dāng)?shù)谝慌娜齻€(gè)進(jìn)程執(zhí)行完后，第二批的三個(gè)再執(zhí)行。所以進(jìn)程池相當(dāng)于起到了緩沖的作用。

實(shí)際上，在進(jìn)程池的方式中，父進(jìn)程基本上只需要等待子進(jìn)程執(zhí)行(使用pool.join()進(jìn)行等待)，任務(wù)都是交給子進(jìn)程執(zhí)行的。

總結(jié)

以上是生活随笔為你收集整理的python点击按钮创建进程_python-创建进程的三种方式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。