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

在審

• 申請?zhí)枺?/td>: 201710202415.0
• 申請日: 2017-03-30
• 公開（公告）號: CN106990943A
• 公開（公告）日: 2017-07-28
• 發(fā)明（設(shè)計(jì)）人: 李傳松
• 申請（專利權(quán)）人: 微夢創(chuàng)科網(wǎng)絡(luò)科技（中國）有限公司
• 主分類號: G06F9/38
• 分類號: G06F9/38
• 代理公司: 北京卓嵐智財(cái)知識產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙)11624
• 代理人: 任漱晨

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種并行任務(wù)處理方法和裝置。

背景技術(shù)

考慮到在計(jì)算機(jī)層面，對于請求的響應(yīng)一般是采用任務(wù)流的方式，即，用戶在前臺發(fā)起一個任務(wù)A提交后臺執(zhí)行，隨后又發(fā)起另一個任務(wù)B或多個任務(wù)。只有在這多個任務(wù)(A、B……)全部執(zhí)行完成后，才會執(zhí)行下一個邏輯模塊。

針對上述情況，現(xiàn)有的做法是：評估任務(wù)執(zhí)行時(shí)間，假設(shè)任務(wù)執(zhí)行時(shí)間：任務(wù)B>任務(wù)A，那么任務(wù)A完成時(shí)，通知任務(wù)B，在任務(wù)B執(zhí)行完后根據(jù)任務(wù)A反饋的狀態(tài)再確定是否要繼續(xù)執(zhí)行下一個模塊。

舉例而言：用戶購買付費(fèi)會員，在提交訂單后，后臺運(yùn)行扣款任務(wù)，頁面繼續(xù)讓用戶發(fā)起分享紅包任務(wù)，在后臺運(yùn)行扣款任務(wù)后，判斷用戶是否分享紅包決定是否發(fā)紅包。然后繼續(xù)下一步。即，發(fā)紅包就是上述的下一個模塊，扣款和分享就是上述任務(wù)A和任務(wù)B。

采用上述方式進(jìn)行處理主要會存在以下幾個問題：

1)考慮不到異常處理，以執(zhí)行時(shí)間作為評估時(shí)間，然而，在實(shí)際執(zhí)行的時(shí)候，可能由于硬件、網(wǎng)絡(luò)、資源問題等，執(zhí)行時(shí)間會發(fā)生偏差。例如：異常情況任務(wù)B執(zhí)行后還沒有得到任務(wù)A的反饋，從而導(dǎo)致執(zhí)行下一個邏輯模塊出錯。

2)效率低，即使改進(jìn)任務(wù)B執(zhí)行后如果沒收到任務(wù)A反饋時(shí)，處于等待狀態(tài)。等任務(wù)A有反饋時(shí)繼續(xù)執(zhí)行，這樣也會降低整個執(zhí)行的效率，且，如果任務(wù)A一直沒反饋，那么會造成大量的堆積現(xiàn)象的產(chǎn)生。

3)系統(tǒng)耦合性高，任務(wù)B是否繼續(xù)或執(zhí)行結(jié)果是否正確，將依賴于任務(wù)A的反饋，如果存在并行任務(wù)很多的情況，系統(tǒng)的復(fù)雜度會成倍上升。

針對上述問題，目前尚未提出有效的解決方案。

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

本發(fā)明實(shí)施例提供一種并行任務(wù)處理方法和裝置，以達(dá)到有效提升并行任務(wù)處理效率，降低系統(tǒng)耦合性的技術(shù)效果。

一方面，本發(fā)明實(shí)施例提供了一種并行任務(wù)處理方法，包括：

確定并行任務(wù)組中當(dāng)前任務(wù)是否執(zhí)行完成；

如果執(zhí)行完成，則將預(yù)先建立的對應(yīng)于所述并行任務(wù)組的會話共享信號區(qū)中所述當(dāng)前任務(wù)的執(zhí)行狀態(tài)調(diào)整為執(zhí)行完成，其中，所述會話共享信號區(qū)用于存放對應(yīng)的并行任務(wù)組中并行執(zhí)行的各個任務(wù)的執(zhí)行狀態(tài)；

在確定所述會話共享信號區(qū)中各個任務(wù)的執(zhí)行狀態(tài)均處于執(zhí)行完成的情況下，執(zhí)行下一并行任務(wù)組中的任務(wù)，其中，所述下一并行任務(wù)組中的任務(wù)是需要依賴當(dāng)前并行任務(wù)組中的各個任務(wù)均執(zhí)行完成才能執(zhí)行的任務(wù)。

在一個實(shí)施方式中，在確定所述會話共享信號區(qū)中存在執(zhí)行狀態(tài)處于未執(zhí)行完成的任務(wù)的情況下，確定所述會話共享信號區(qū)是否超出預(yù)設(shè)的過期時(shí)長；

如果超出，則初始化所述會話共享信號區(qū)中的執(zhí)行狀態(tài)和過期時(shí)長。

在一個實(shí)施方式中，所述會話共享信號區(qū)中通過0和1標(biāo)識任務(wù)的執(zhí)行狀態(tài)。

在一個實(shí)施方式中，在確定并行任務(wù)組中當(dāng)前任務(wù)是否執(zhí)行完成之前，所述方法還包括：

接收到并行任務(wù)組發(fā)起請求；

響應(yīng)于所述并行任務(wù)組發(fā)起請求，建立所述并行任務(wù)組對應(yīng)的會話共享信號區(qū)；

初始化所述會話共享信號區(qū)中的執(zhí)行狀態(tài)和過期時(shí)長。

在一個實(shí)施方式中，將預(yù)先建立的對應(yīng)于所述并行任務(wù)組的會話共享信號區(qū)中所述當(dāng)前任務(wù)的執(zhí)行狀態(tài)調(diào)整為執(zhí)行完成,，包括：

獲取所述當(dāng)前任務(wù)的任務(wù)標(biāo)識；

根據(jù)所述當(dāng)前任務(wù)的任務(wù)標(biāo)識，從所述會話共享信號區(qū)中查找出所述當(dāng)前任務(wù)對應(yīng)的執(zhí)行狀態(tài)；

將查找出的所述當(dāng)前任務(wù)對應(yīng)的執(zhí)行狀態(tài)調(diào)整為執(zhí)行完成。

另一方面，本發(fā)明實(shí)施例提供了一種并行任務(wù)處理裝置，包括：

第一確定模塊，用于確定并行任務(wù)組中當(dāng)前任務(wù)是否執(zhí)行完成；

調(diào)整模塊，用于在第一確定模塊確定所述當(dāng)前任務(wù)執(zhí)行完成的情況下，將預(yù)先建立的對應(yīng)于所述并行任務(wù)組的會話共享信號區(qū)中所述當(dāng)前任務(wù)的執(zhí)行狀態(tài)調(diào)整為執(zhí)行完成，其中，所述會話共享信號區(qū)用于存放對應(yīng)的并行任務(wù)組中并行執(zhí)行的各個任務(wù)的執(zhí)行狀態(tài)；

執(zhí)行模塊，用于在確定所述會話共享信號區(qū)中各個任務(wù)的執(zhí)行狀態(tài)均已經(jīng)處于執(zhí)行完成狀態(tài)的情況下，執(zhí)行下一并行任務(wù)組中的任務(wù)，其中，所述下一并行任務(wù)組中的任務(wù)是需要依賴當(dāng)前并行任務(wù)組中的各個任務(wù)均執(zhí)行完成才能執(zhí)行的任務(wù)。

在一個實(shí)施方式中，上述裝置還包括：

第二確定模塊，用于在確定所述會話共享信號區(qū)中存在執(zhí)行狀態(tài)處于未執(zhí)行完成的任務(wù)的情況下，確定所述會話共享信號區(qū)是否超出預(yù)設(shè)的過期時(shí)長；