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

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

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

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

謝謝了先！

回答
編輯回答
久不遇

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

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