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

在審

• 申請?zhí)枺?/td>: 201710042524.0
• 申請日: 2017-01-20
• 公開（公告）號: CN106970834A
• 公開（公告）日: 2017-07-21
• 發(fā)明（設(shè)計(jì)）人: 袁自誠;連琨;汪一鳴
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/46
• 代理公司: 北京鼎佳達(dá)知識產(chǎn)權(quán)代理事務(wù)所(普通合伙)11348
• 代理人: 王偉鋒,劉鐵生

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，特別是涉及一種任務(wù)處理的方法及裝置。

背景技術(shù)

在互聯(lián)網(wǎng)普及的時(shí)代，往往需要通過處理任務(wù)的方式實(shí)現(xiàn)數(shù)據(jù)的更新，例如實(shí)現(xiàn)兩個(gè)數(shù)據(jù)表的同步、實(shí)現(xiàn)系統(tǒng)的更新等。在實(shí)際應(yīng)用中，因數(shù)據(jù)表之間存在外鍵依賴等原因，使得不同任務(wù)之間可能會(huì)存在依賴關(guān)系，例如任務(wù)1依賴任務(wù)2的執(zhí)行結(jié)果。然而，在實(shí)際應(yīng)用中，任務(wù)處理系統(tǒng)接收到的任務(wù)可能是無序的，即不是按照依賴順序依次接收到對應(yīng)的任務(wù)，從而導(dǎo)致任務(wù)處理產(chǎn)生困難。例如，任務(wù)1依賴任務(wù)2的執(zhí)行結(jié)果，但是任務(wù)處理系統(tǒng)卻先接收到任務(wù)1，從而導(dǎo)致任務(wù)1無法處理。

為了解決上述問題，現(xiàn)有技術(shù)中提出了一種方案：在將所有的任務(wù)都接收到之后，將這些任務(wù)存儲在一個(gè)臨時(shí)表中，并基于各個(gè)任務(wù)之間的依賴關(guān)系，整理所有任務(wù)的處理順序，最后按照整理后的順序，依次處理各個(gè)任務(wù)。但是，當(dāng)任務(wù)多且依賴關(guān)系復(fù)雜時(shí)，整理處理順序的效率會(huì)大大降低，且由于是在接收到所有任務(wù)并對任務(wù)進(jìn)行排序之后，才開始處理任務(wù)，所以導(dǎo)致整個(gè)系統(tǒng)處理任務(wù)的效率降低。

發(fā)明內(nèi)容

有鑒于此，本發(fā)明提供一種任務(wù)處理的方法及裝置，能夠解決現(xiàn)有技術(shù)中當(dāng)任務(wù)依賴關(guān)系較復(fù)雜時(shí)，任務(wù)處理效率低的問題。

一方面，本發(fā)明提供了一種任務(wù)處理的方法，所述方法包括：

判斷待處理任務(wù)是否含有依賴任務(wù)，所述依賴任務(wù)為所述待處理任務(wù)所依賴的任務(wù)；

若所述待處理任務(wù)含有依賴任務(wù)，則使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)；

當(dāng)監(jiān)聽到所述依賴任務(wù)的回調(diào)通知后，處理所述待處理任務(wù)。

可選的，所述方法還包括：

在將所述待處理任務(wù)處理完成后，廣播用于指示任務(wù)處理完成的回調(diào)通知，或者當(dāng)確定所述待處理任務(wù)被其他任務(wù)訂閱時(shí)，將回調(diào)通知發(fā)送給訂閱所述待處理任務(wù)的其他任務(wù)，以便訂閱所述待處理任務(wù)的其他任務(wù)接收到所述回調(diào)通知后，進(jìn)行任務(wù)處理操作。

可選的，在使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)之前，所述方法還包括：

判斷所述依賴任務(wù)是否處理完成；

所述使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)包括：

若所述依賴任務(wù)未處理完成，則使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)。

可選的，所述判斷所述依賴任務(wù)是否處理完成包括：

判斷所述待處理任務(wù)是否能夠正常處理；

若所述待處理任務(wù)不能正常處理，則確定所述依賴任務(wù)未處理完成。

可選的，所述判斷待處理任務(wù)是否含有依賴任務(wù)包括：

判斷所述待處理任務(wù)中是否記載有處理基礎(chǔ)；

若所述待處理任務(wù)中記載有處理基礎(chǔ)，則確定所述待處理任務(wù)含有依賴任務(wù)。

另一方面，本發(fā)明提供了一種任務(wù)處理的裝置，所述裝置包括：

判斷單元，用于判斷待處理任務(wù)是否含有依賴任務(wù)，所述依賴任務(wù)為所述待處理任務(wù)所依賴的任務(wù)；

訂閱單元，用于當(dāng)所述判斷單元的判斷結(jié)果為所述待處理任務(wù)含有依賴任務(wù)時(shí)，使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)；

處理單元，用于當(dāng)監(jiān)聽到所述依賴任務(wù)的回調(diào)通知后，處理所述待處理任務(wù)。

可選的，所述裝置還包括：

廣播單元，用于在將所述待處理任務(wù)處理完成后，廣播用于指示任務(wù)處理完成的回調(diào)通知，以便訂閱所述待處理任務(wù)的其他任務(wù)接收到所述回調(diào)通知后，進(jìn)行任務(wù)處理操作；

發(fā)送單元，用于當(dāng)確定所述待處理任務(wù)被其他任務(wù)訂閱時(shí)，將回調(diào)通知發(fā)送給訂閱所述待處理任務(wù)的其他任務(wù)，以便訂閱所述待處理任務(wù)的其他任務(wù)接收到所述回調(diào)通知后，進(jìn)行任務(wù)處理操作。

可選的，所述判斷單元還用于在使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)之前，判斷所述依賴任務(wù)是否處理完成；

所述訂閱單元用于當(dāng)所述依賴任務(wù)未處理完成時(shí)，使得所述待處理任務(wù)訂閱所述依賴任務(wù)的回調(diào)服務(wù)。

可選的，所述判斷單元包括：

第一判斷模塊，用于判斷所述待處理任務(wù)是否能夠正常處理；

第一確定模塊，用于當(dāng)所述第一判斷模塊的判斷結(jié)果為所述待處理任務(wù)不能正常處理時(shí)，確定所述依賴任務(wù)未處理完成。

可選的，所述判斷單元包括：

第二判斷模塊，用于判斷所述待處理任務(wù)中是否記載有處理基礎(chǔ)；

第二確定模塊，用于當(dāng)所述第二判斷模塊的判斷結(jié)果為所述待處理任務(wù)中記載有處理基礎(chǔ)時(shí)，確定所述待處理任務(wù)含有依賴任務(wù)。