[發(fā)明專利]一種處理任務(wù)的方法及裝置

在審

• 申請?zhí)枺?/td>: 201810072775.8
• 申請日: 2018-01-25
• 公開（公告）號: CN108287756A
• 公開（公告）日: 2018-07-17
• 發(fā)明（設(shè)計）人: 唐翌飛;趙曉慶;吳鋒海
• 申請（專利權(quán)）人: 聯(lián)動優(yōu)勢科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京同達信恒知識產(chǎn)權(quán)代理有限公司 11291
• 代理人: 黃志華

1.一種處理任務(wù)的方法，其特征在于，所述方法包括：

管理服務(wù)器根據(jù)獲取的任務(wù)，確定所述任務(wù)中的各子任務(wù)間的依賴關(guān)系；

所述管理服務(wù)器根據(jù)所述各子任務(wù)間的依賴關(guān)系，確定所述各子任務(wù)的前置任務(wù)；

所述管理服務(wù)器將前置任務(wù)狀態(tài)為完成或無前置任務(wù)的子任務(wù)，確定為待處理的子任務(wù)；

所述管理服務(wù)器將所述待處理的子任務(wù)發(fā)送給執(zhí)行服務(wù)器，并接收所述執(zhí)行服務(wù)器反饋的所述待處理的子任務(wù)的執(zhí)行結(jié)果；

所述管理服務(wù)器在所述待處理的子任務(wù)的執(zhí)行結(jié)果為成功時，更新關(guān)聯(lián)子任務(wù)的前置任務(wù)狀態(tài)，所述待處理的子任務(wù)為所述關(guān)聯(lián)子任務(wù)的前置任務(wù)；返回至確定為待處理的子任務(wù)的步驟，直至所述任務(wù)中的各子任務(wù)執(zhí)行完成。

2.如權(quán)利要求1所述的方法，其特征在于，所述管理服務(wù)器根據(jù)所述各子任務(wù)間的依賴關(guān)系，確定所述各子任務(wù)的前置任務(wù)，包括：

所述管理服務(wù)器按照所述各子任務(wù)間的依賴關(guān)系，將所述各子任務(wù)加入子任務(wù)隊列，所述子任務(wù)隊列中，子任務(wù)的前置任務(wù)位于該子任務(wù)之前；

所述管理服務(wù)器將前置任務(wù)狀態(tài)為完成或無前置任務(wù)的子任務(wù)，確定為待處理的子任務(wù)，包括：

所述管理服務(wù)器從所述子任務(wù)隊列中獲取子任務(wù)，在確定所述子任務(wù)的前置任務(wù)狀態(tài)為完成或無前置任務(wù)時，確定所述子任務(wù)為待處理的子任務(wù)。

3.如權(quán)利要求1所述的方法，其特征在于，所述管理服務(wù)器按照所述各子任務(wù)間的依賴關(guān)系，將所述各子任務(wù)加入子任務(wù)隊列，包括：

所述管理服務(wù)器確定所述任務(wù)中的各任務(wù)節(jié)點對應(yīng)的任務(wù)組，并按照各任務(wù)節(jié)點之間的執(zhí)行依賴關(guān)系將所述各任務(wù)組加入任務(wù)組隊列；

所述管理服務(wù)器針對所述任務(wù)組隊列中的任一任務(wù)組，確定該任務(wù)組中的各子任務(wù)；按照各子任務(wù)間的依賴關(guān)系，將所述各子任務(wù)加入該任務(wù)組的子任務(wù)隊列；

所述管理服務(wù)器將前置任務(wù)狀態(tài)為完成或無前置任務(wù)的子任務(wù)，確定為待處理的子任務(wù)，包括：

所述管理服務(wù)器將前置任務(wù)狀態(tài)為完成或無前置任務(wù)組的任務(wù)組，確定為待處理的任務(wù)組；所述任務(wù)組的前置任務(wù)狀態(tài)根據(jù)所述任務(wù)組的前置任務(wù)組內(nèi)各子任務(wù)的任務(wù)狀態(tài)確定；

所述管理服務(wù)器從所述待處理的任務(wù)組的子任務(wù)隊列中，獲取子任務(wù)，在確定所述子任務(wù)的前置任務(wù)狀態(tài)為完成或無前置任務(wù)時，確定所述子任務(wù)為待處理的子任務(wù)。

4.如權(quán)利要求3所述的方法，其特征在于，所述方法還包括：

所述管理服務(wù)器若確定所述待處理的子任務(wù)的執(zhí)行結(jié)果為失敗，則將所述待處理的子任務(wù)的執(zhí)行次數(shù)加一，并將所述待處理的子任務(wù)重新加入至所述子任務(wù)隊列中；

所述管理服務(wù)器若確定所述待處理的子任務(wù)的執(zhí)行次數(shù)超過預(yù)設(shè)閾值，則將所述待處理的子任務(wù)的任務(wù)狀態(tài)確定為失敗。

5.如權(quán)利要求1至4任一項所述的方法，其特征在于，所述管理服務(wù)器將所述待處理的子任務(wù)發(fā)送給執(zhí)行服務(wù)器，包括：

所述管理服務(wù)器通過分布式服務(wù)器集群向各執(zhí)行服務(wù)器發(fā)送所述待處理的子任務(wù)；所述各執(zhí)行服務(wù)器用于并行執(zhí)行各待處理的子任務(wù)。

6.一種處理任務(wù)的裝置，其特征在于，所述裝置包括：

獲取單元，用于獲取任務(wù)；

處理單元，用于根據(jù)獲取的所述任務(wù)，確定所述任務(wù)中的各子任務(wù)間的依賴關(guān)系；根據(jù)所述各子任務(wù)間的依賴關(guān)系，確定所述各子任務(wù)的前置任務(wù)；將前置任務(wù)狀態(tài)為完成或無前置任務(wù)的子任務(wù)，確定為待處理的子任務(wù)；將所述待處理的子任務(wù)發(fā)送給執(zhí)行服務(wù)器，并接收所述執(zhí)行服務(wù)器反饋的所述待處理的子任務(wù)的執(zhí)行結(jié)果；在所述待處理的子任務(wù)的執(zhí)行結(jié)果為成功時，更新關(guān)聯(lián)子任務(wù)的前置任務(wù)狀態(tài)，所述待處理的子任務(wù)為所述關(guān)聯(lián)子任務(wù)的前置任務(wù)；返回至確定為待處理的子任務(wù)的步驟，直至所述任務(wù)中的各子任務(wù)執(zhí)行完成。

7.如權(quán)利要求6所述的裝置，其特征在于，所述處理單元還用于：

按照所述各子任務(wù)間的依賴關(guān)系，將所述各子任務(wù)加入子任務(wù)隊列，所述子任務(wù)隊列中，子任務(wù)的前置任務(wù)位于該子任務(wù)之前；從所述子任務(wù)隊列中獲取子任務(wù)，在確定所述子任務(wù)的前置任務(wù)狀態(tài)為完成或無前置任務(wù)時，確定所述子任務(wù)為待處理的子任務(wù)。