[發明專利]計算任務處理方法、裝置、服務器及存儲介質

有效

• 申請號: 201911421294.4
• 申請日: 2019-12-31
• 公開（公告）號: CN111522635B
• 公開（公告）日: 2023-10-20
• 發明（設計）人: 秦昌雷
• 申請（專利權）人: 支付寶實驗室（新加坡）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06Q40/12
• 代理公司: 北京眾達德權知識產權代理有限公司 11570
• 代理人: 張桂蓉

1.一種計算任務處理方法，包括：

獲取計算任務，所述計算任務包含存在關聯邏輯的一個以上計算單元；

通過計算引擎從預先配置的一種以上任務模版中，調用與所述計算任務匹配的目標任務模版，所述目標任務模版包含對所述計算任務中每個計算單元的定義信息以及表征所述計算任務中各計算單元之間關聯邏輯的關系鏈信息；

根據所述目標任務模版中對所述計算任務中每個計算單元的定義信息以及所述關系鏈信息，對所述計算任務進行處理。

2.如權利要求1所述的方法，所述根據所述目標任務模版中對所述計算任務中每個計算單元的定義信息以及所述關系鏈信息，對所述計算任務進行處理，包括：

根據所述目標任務模版中對所述計算任務中每個計算單元的定義信息以及所述關系鏈信息，對所述計算任務進行循環關聯計算，其中，所述目標任務模版為循環關聯任務模版，所述循環關聯計算包含對所述計算任務中至少一個計算單元的多次計算，或者

根據所述目標任務模版中對所述計算任務中每個計算單元的定義信息以及所述關系鏈信息，對所述計算任務進行順序關聯計算，其中，所述目標任模版為順序關聯任務模版，所述順序關聯計算包含對所述計算任務中每個計算單元的單次計算。

3.如權利要求1所述的方法，所述計算任務包含N個，所述根據所述目標任務模版中對所述計算任務中每個計算單元的定義信息以及所述關系鏈信息，對所述計算任務進行處理，包括：

將每個所述計算任務放入預先創建的線程池中，使得在所述線程池中存在N個計算任務對應的N個待執行隊列，每個所述計算任務的待執行隊列中包含該計算任務中未執行的計算單元，N為正整數；

基于所述線程池的線程調度，從所述N個待執行隊列中并發調度所述N個計算任務中每個計算任務的當前計算單元；

針對所述N個計算任務中每個計算任務的當前計算單元，根據與所述計算任務匹配的目標任務模版中關系鏈信息以及所述當前計算單元的定義信息，對所述當前計算單元進行計算，得到每個所述當前計算單元的計算結果。

4.如權利要求3所述的方法，在從所述N個待執行隊列中并發調度所述N個計算任務中每個計算任務的當前計算單元的步驟中，每個計算任務的當前計算單元，通過如下步驟進行調度：

從所述計算任務的待執行隊列中串行調度所述計算任務的當前計算單元時，檢查所述當前計算單元的前置計算單元是否計算完成，所述當前計算單元與所述前置計算單元屬于同一計算任務；

如果所述前置計算單元已經計算完成，則執行所述當前計算單元；

否則，重新將所述當前計算單元添加至所述計算任務的待執行隊列中，以等待所述線程池的下一次調度。

5.如權利要求4所述的方法，所述從所述計算任務的待執行隊列中串行調度所述計算任務的當前計算單元，包括：

根據所述關系鏈信息，從所述計算任務的待執行隊列中獲取該計算任務的當前計算單元，以及

根據所述關系鏈信息，確定所述當前計算單元的前置計算單元。

6.如權利要求4所述的方法，所述計算任務中每個計算單元的定義信息包括：該計算單元在所述計算任務中的唯一身份標識、該計算單元的計算基準依據以及計算規則；

所述計算任務的每個計算單元中記錄有該計算單元的關聯計算單元和循環次數，所述關系鏈信息基于所述計算任務的每個計算單元中記錄的關聯計算單元和循環次數形成。

7.如權利要求6所述的方法，所述執行所述當前計算單元，包括：

根據所述當前計算單元的計算基準依據確定所述當前計算單元的當前次計算基準量；

根據所述當前計算單元的計算規則以及當前次計算基準量，執行對所述當前計算單元的本次計算，得到所述當前計算單元的本次計算結果；

向數據使用方輸出所述當前計算單元的本次計算結果，其中，所述數據使用方為所述當前計算單元或者所述當前計算單元的關聯計算單元。