[發明專利]異步任務執行方法、異步調度系統、裝置、設備和介質

在審

• 申請號: 202310137244.3
• 申請日: 2023-02-10
• 公開（公告）號: CN116225647A
• 公開（公告）日: 2023-06-06
• 發明（設計）人: 胡琳;鄒泳彤;李俊杰;周潤坤
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/38
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 張體南

1.一種異步任務執行方法，由分布式服務節點執行，包括：

向控制中心發起異步任務執行請求，其中，所述控制中心被配置為接收N個分布式服務節點中至少部分節點發起的異步任務執行請求，N大于或等于2；

接收所述控制中心響應于所述異步任務執行請求而返回的執行權結果；

若獲取到異步任務執行權，則確定異步并發數量；

并發執行與所述異步并發數量對應的異步任務。

2.根據權利要求1所述的方法，其中，若獲取到異步任務執行權，在所述確定異步并發數量之前，所述方法還包括：

向所述控制中心發起異常節點清理請求，其中，所述異常節點包括所述N個分布式服務節點中被所述控制中心檢測出異常的節點；

從所述控制中心獲取所述N個分布式服務節點中具有所述異步任務執行權的節點數量；

在所述節點數量小于并發節點數閾值的情況下，確定成功獲取所述異步任務執行權。

3.根據權利要求1或2所述的方法，其中，若未獲取到所述異步任務執行權，所述方法還包括：

每隔第一預定時間段重復執行所述向控制中心發起異步任務執行請求的操作，并接收所述執行權結果。

4.根據權利要求1或2所述的方法，其中，所述方法還包括：

每隔第二預定時間段向所述控制中心上報心跳信息，其中，所述控制中心被配置為若未接收到該分布式服務節點的心跳信息，將其異步任務執行權分配至其他節點。

5.根據權利要求1所述的方法，其中，所述確定異步并發數量包括：

向令牌管理器申請令牌，其中，所述令牌管理器被配置為根據所述控制中心的令牌控制數量發放所述令牌；

根據申請到的所述令牌的數量確定所述異步并發數量。

6.根據權利要求5所述的方法，其中，所述令牌管理器被安裝在該分布式服務節點中，利用所述令牌管理器執行以下操作：

每隔第三預定時間段向所述控制中心查詢所述令牌控制數量，其中，所述控制中心被配置為動態調整所述令牌控制數量；

將所述控制中心返回的最新所述令牌控制數量與令牌總數進行比對，獲得比對結果，所述令牌總數包括已發令牌和待發令牌；

根據所述比對結果發放或回收所述令牌。

7.一種異步任務執行方法，由控制中心執行，包括：

接收N個分布式服務節點中至少部分節點發起的異步任務執行請求，N大于或等于2；

響應于所述異步任務執行請求，根據并發節點數閾值向所述N個分布式服務節點返回執行權結果；

其中，所述N個分布式服務節點中Q個分布式服務節點獲取到異步任務執行權，所述Q個分布式服務節點中任一節點被配置為確定該節點的異步并發數量，并發執行與所述異步并發數量對應的異步任務，Q小于或等于N。

8.根據權利要求7所述的方法，其中，所述方法還包括：

接收所述Q個分布式服務節點中任一節點發起的異常節點清理請求，其中，所述異常節點包括所述N個分布式服務節點中被所述控制中心檢測出異常的節點；

在清理異常節點后，向所述Q個分布式服務節點中任一節點返回具有所述異步任務執行權的節點數量。

9.根據權利要求7所述的方法，其中，所述方法還包括：

每隔第一預定時間段接收所述N個分布式服務節點中除所述Q個分布式服務節點之外的任一節點發起的異步任務執行請求，并返回執行權結果；和/或

每隔第二預定時間段接收所述N個分布式服務節點中至少部分節點上報的心跳信息，其中，所述控制中心被配置為若未接收到所述Q個分布式服務節點中任一節點的心跳信息，將其異步任務執行權分配至其他節點；和/或

每隔第三預定時間段接收所述Q個分布式服務節點中任一節點查詢令牌控制數量的請求，并將經動態調整的最新所述令牌控制數量返回給查詢節點。