[發(fā)明專(zhuān)利]一種任務(wù)執(zhí)行的方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201711049658.1
• 申請(qǐng)日: 2017-10-31
• 公開(kāi)（公告）號(hào): CN109725989B
• 公開(kāi)（公告）日: 2020-07-31
• 發(fā)明（設(shè)計(jì)）人: 林文珍
• 申請(qǐng)（專(zhuān)利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類(lèi)號(hào): G06F9/48
• 分類(lèi)號(hào): G06F9/48
• 代理公司: 北京晉德允升知識(shí)產(chǎn)權(quán)代理有限公司 11623
• 代理人: 楊移

1.一種任務(wù)執(zhí)行的方法，包括：

接收任務(wù)請(qǐng)求；

根據(jù)所述任務(wù)請(qǐng)求生成有向無(wú)環(huán)圖DAG的葉子節(jié)點(diǎn)，以及確定所述DAG的節(jié)點(diǎn)總數(shù)，其中，所述DAG的各葉子節(jié)點(diǎn)用于將所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)拆分為若干個(gè)子任務(wù)；

將所述葉子節(jié)點(diǎn)作為待執(zhí)行節(jié)點(diǎn)，以及確定所述待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行，得到執(zhí)行結(jié)果；

根據(jù)已執(zhí)行了對(duì)應(yīng)的任務(wù)的節(jié)點(diǎn)數(shù)量以及所述節(jié)點(diǎn)總數(shù)，判斷所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)是否執(zhí)行完畢；

若是，則將所述執(zhí)行結(jié)果作為任務(wù)結(jié)果；

若否，則根據(jù)所述執(zhí)行結(jié)果生成下游節(jié)點(diǎn)，并將所述下游節(jié)點(diǎn)作為待執(zhí)行節(jié)點(diǎn)，繼續(xù)執(zhí)行待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)，直至確定所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)執(zhí)行完畢為止；

其中，確定所述DAG的節(jié)點(diǎn)總數(shù)，具體包括：

根據(jù)預(yù)設(shè)的任務(wù)組裝條件以及所述葉子節(jié)點(diǎn)的數(shù)量，確定所述DAG的節(jié)點(diǎn)總數(shù)；

將所述葉子節(jié)點(diǎn)作為待執(zhí)行節(jié)點(diǎn)，以及確定所述待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行，具體包括：

確定滿足所述任務(wù)組裝條件的待執(zhí)行節(jié)點(diǎn)，添加至執(zhí)行隊(duì)列，確定不滿足所述任務(wù)組裝條件的待執(zhí)行節(jié)點(diǎn)，添加至準(zhǔn)備隊(duì)列；

根據(jù)所述任務(wù)組裝條件，組裝所述執(zhí)行隊(duì)列中的待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行；

將所述下游節(jié)點(diǎn)作為待執(zhí)行節(jié)點(diǎn)，以及確定所述待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行，具體包括：

將所述下游節(jié)點(diǎn)作為待執(zhí)行節(jié)點(diǎn)添加至所述準(zhǔn)備隊(duì)列；

判斷所述準(zhǔn)備隊(duì)列中是否存在滿足所述任務(wù)組裝條件的待執(zhí)行節(jié)點(diǎn)；

若是，則將滿足所述任務(wù)組裝條件的待執(zhí)行節(jié)點(diǎn)移動(dòng)至所述執(zhí)行隊(duì)列，以根據(jù)所述任務(wù)組裝條件，組裝所述執(zhí)行隊(duì)列中的待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行；

若否，則等待其他待執(zhí)行節(jié)點(diǎn)添加至所述準(zhǔn)備隊(duì)列。

2.如權(quán)利要求1所述的方法，根據(jù)所述任務(wù)請(qǐng)求生成有向無(wú)環(huán)圖DAG的葉子節(jié)點(diǎn)，具體包括：

根據(jù)所述任務(wù)請(qǐng)求，確定執(zhí)行所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)需要輸入的數(shù)據(jù)；

根據(jù)確定出的數(shù)據(jù)生成所述DAG中的各葉子節(jié)點(diǎn)。

3.如權(quán)利要求1所述的方法，確定所述待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行，得到執(zhí)行結(jié)果之后，所述方法還包括：

將所述待執(zhí)行節(jié)點(diǎn)作為已執(zhí)行節(jié)點(diǎn)移出所述執(zhí)行隊(duì)列。

4.如權(quán)利要求1所述的方法，根據(jù)已執(zhí)行了對(duì)應(yīng)的任務(wù)的節(jié)點(diǎn)數(shù)量以及所述節(jié)點(diǎn)總數(shù)，判斷所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)是否執(zhí)行完畢，具體包括：

判斷已生成的節(jié)點(diǎn)數(shù)量是否等于所述節(jié)點(diǎn)總數(shù)，判斷所述準(zhǔn)備隊(duì)列以及所述執(zhí)行隊(duì)列是否均為空；

若判斷結(jié)果均是，則確定所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)執(zhí)行完畢；

若任一判斷結(jié)果為否，則確定所述任務(wù)請(qǐng)求對(duì)應(yīng)的任務(wù)未執(zhí)行完畢。

5.如權(quán)利要求1所述的方法，所述任務(wù)請(qǐng)求為：從若干數(shù)據(jù)中確定極值數(shù)據(jù)的請(qǐng)求。

6.如權(quán)利要求1所述的方法，確定所述待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)并執(zhí)行，得到執(zhí)行結(jié)果，具體包括：

確定所述待執(zhí)行節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)，并將待執(zhí)行任務(wù)發(fā)送至執(zhí)行方，以使所述執(zhí)行方執(zhí)行所述任務(wù)，并將執(zhí)行結(jié)果返回。