鍍金池/ 問(wèn)答/Python  網(wǎng)絡(luò)安全/ 請(qǐng)問(wèn)：Python的multi-processing模塊怎么讓快的任務(wù)等待慢的任

請(qǐng)問(wèn)：Python的multi-processing模塊怎么讓快的任務(wù)等待慢的任務(wù)？

請(qǐng)教一個(gè)Python的multi-processing模塊互相等待、防止競(jìng)爭(zhēng)的問(wèn)題。現(xiàn)在我有2個(gè)任務(wù)，任務(wù)1和任務(wù)2，要么1比2快、要么2比1快?，F(xiàn)在要并發(fā)同時(shí)執(zhí)行2個(gè)任務(wù)，快的完畢之后等待慢的。等待2個(gè)任務(wù)都結(jié)束之后，然后系統(tǒng)再轉(zhuǎn)而運(yùn)行第3個(gè)任務(wù)。

我嘗試了一下apply_async：

import time
from multiprocessing import Pool

def func1():
    print "This starts task1."
    time.sleep(1)
    print "This ends task1."
def func2():
    print "This starts task2."
    time.sleep(2)
    print "This ends task2."
def func3(x):
    print x
    
pool = Pool(processes=3)
result = pool.apply_async(func1, func2)
pool.start()
pool.join()

我覺得還是不對(duì)，但是不清楚正確的應(yīng)該怎么寫。另外，平臺(tái)是Python2.7，所以高級(jí)一點(diǎn)的Asyncio就沒法用了。請(qǐng)問(wèn)這個(gè)快的等待慢的、然后兩個(gè)全部結(jié)束后再運(yùn)行新任務(wù)的并發(fā)執(zhí)行應(yīng)該怎么設(shè)計(jì)呢？

謝謝了先！

回答
編輯回答
久不遇

apply_async(func[, args[, kwds[, callback]]])
你的用法明顯不對(duì)嗎。

import time
from multiprocessing import Pool

def func(n):
    print "This starts task{}.".format(n)
    time.sleep(n)
    print "This ends task{}.".format(n)

    
pool = Pool(processes=3)
pool.map(func, range(3))
pool.join()
2018年8月7日 16:15