[發明專利]基于隊列的任務執行流程控制方法及系統

在審

• 申請號: 202010849082.2
• 申請日: 2020-08-21
• 公開（公告）號: CN112000476A
• 公開（公告）日: 2020-11-27
• 發明（設計）人: 王鋒;聞斌;朱容慶
• 申請（專利權）人: 南京星鄴匯捷網絡科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54;G06Q10/06
• 代理公司: 北京眾合誠成知識產權代理有限公司 11246
• 代理人: 戚星

本發明實施例公開了任務執行處理技術領域的基于隊列的任務執行流程控制方法及系統。本發明的基于隊列的任務執行流程控制方法，包括S1、通過WEB功能界面配置完成任務X；S2、啟動任務執行流程，任務X通過功能模塊start執行完成后，執行結果按照任務流轉承載結構體封裝好，推送至任務隊列01；S3、在任務隊列01中的任務X會被推送至功能模塊P01進行消費，而后將執行結果按照任務流轉承載結構封裝好。本發明利用任務隊列作為任務在流轉過程中的消息的載體，多個功能模塊之間相對隔離；只需關注本身模塊的執行的任務消費來自哪個隊列以及任務執行完之后將任務推送至哪個隊列即可；同時定義一個標準的任務流轉程承載消息的結構體。

技術領域

本發明實施例涉及任務執行處理技術領域，尤其涉及基于隊列的任務執行流程控制方法及系統。

背景技術

目前針對一項任務的執行，中間經歷了多個功能模塊。傳統的做法是當其中某一個功能模塊執行完成后，主動送給下一個執行功能模塊。當任務執行量增大時，會面臨如下幾個問題：一是當前功能模塊執行完成后往下一個功能模塊送時，需要做一定的策略判斷，具體送給哪一個，這期間消耗本身性能；二是如果一個中間功能模塊由于執行任務緩慢，導致對前一個功能模塊的送達消息無法響應，會引起任務流轉的堵塞，導致任務執行的不連續性，甚至是任務執行的不完整；三是如果中間功能模塊需要新增，則需要同步修改相鄰的前后兩個功能模塊。靈活性較差，增加開發量和后續的維護量。

基于此，本發明設計了基于隊列的任務執行流程控制方法及系統，以解決上述問題。

發明內容

本發明實施例提供基于隊列的任務執行流程控制方法及系統，以解決背景技術中提及的技術問題。

本發明實施例提供基于隊列的任務執行流程控制方法。在一種可行的方案中，包括如下步驟：

S1、通過WEB功能界面配置完成任務X；

S2、啟動任務執行流程，任務X通過功能模塊start執行完成后，執行結果按照任務流轉承載結構體封裝好，推送至任務隊列01；

S3、在任務隊列01中的任務X會被推送至功能模塊P01進行消費，而后將執行結果按照任務流轉承載結構封裝好，并加上功能模塊P01處的匹配信息，推送至任務隊列02，直至推送至完成任務X所需的功能模塊end；

S4、在功能模塊P01至功能模塊end對任務X消費時，將任務X的任務編號在內存庫中查找分別與功能模塊P01至功能模塊end相對應的處理規則，并根據處理規則，分別對功能模塊P01至功能模塊end進行優先處理。

本發明實施例提供基于隊列的任務執行流程控制方法。在一種可行的方案中，所述S1中的任務X配置有需要經歷的中間功能模塊任務執行規則以及完成同步加載的內存。

本發明實施例提供基于隊列的任務執行流程控制方法。在一種可行的方案中，所述S3、S4中功能模塊P01至功能模塊end時刻消費指定的任務隊列01至任務隊列end。

本發明實施例提供基于隊列的任務執行流程控制方法。在一種可行的方案中，所述S3中的匹配信息包括匹配時間信息和匹配結果信息。

本發明實施例還提供基于隊列的任務執行流程控制系統。在一種可行的方案中，包括任務配置模塊、功能執行模塊、任務隊列模塊、查詢控制模塊以及內存庫模塊；

所述任務配置模塊，用于配置指定任務的所有任務執行規則；

所述功能執行模塊，用于分別執行該任務的所有任務執行規則；

所述任務隊列模塊，用于未處理的任務執行規則加上在所述功能執行模塊上的匹配時間以及匹配結果進行任務處理的排隊；

所述查詢控制模塊，用于查詢所述功能執行模塊的執行規則在所述內存庫模塊是否存在相對應的處理規則；