[發明專利]處理任務的方法、裝置、設備和計算機可讀介質

在審

• 申請號: 202110752934.0
• 申請日: 2021-07-02
• 公開（公告）號: CN113485806A
• 公開（公告）日: 2021-10-08
• 發明（設計）人: 唐成山;卞嘉駿;陳軍;趙立才
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 郭晗;趙迪

1.一種處理任務的方法，其特征在于，包括：

按照主任務的處理狀態，定時篩選出滿足子任務分片的主任務；

依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中；

在所述子任務信息表中，通過主任務下屬子任務的執行狀態，周期性確定發送至分布式集群的子任務；

在分布式集群中，執行所述發送至分布式集群的子任務。

2.根據權利要求1所述處理任務的方法，其特征在于，所述按照主任務的處理狀態，定時篩選出滿足子任務分片的主任務，包括：

按照主任務的處理狀態，定時篩選出主任務預處理已完成且分布式消息未下發的主任務。

3.根據權利要求1所述處理任務的方法，其特征在于，所述主任務的處理狀態是通過主任務的狀態代碼獲知的。

4.根據權利要求1所述處理任務的方法，其特征在于，所述依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，包括：

依據所述主任務的類型的標志，將所述主任務拆分為一個串行子任務，或多個并行子任務。

5.根據權利要求1所述處理任務的方法，其特征在于，所述主任務的類型的標識是串行標識；

所述依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中，包括：

依據所述主任務的類型，將所述主任務拆分為一個串行子任務，并將所述串行子任務的信息存儲在子任務信息表中。

6.根據權利要求1所述處理任務的方法，其特征在于，所述主任務的類型的標識是并行標識；

所述依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中，包括：

依據所述主任務的類型，將所述主任務拆分為多個并行子任務，并將所述并行子任務的信息存儲在子任務信息表中。

7.根據權利要求6所述處理任務的方法，其特征在于，所述將所述主任務拆分為多個并行子任務，包括：

按照預設分片數量，將所述主任務拆分為預設分片數量個子任務組，所述子任組中包括一個或多個并行子任務。

8.根據權利要求6所述處理任務的方法，其特征在于，所述將所述主任務拆分為多個并行子任務，包括：

按照所述并行子任務的數量和子任務組中并行子任務的數量，將所述主任務拆分為一個或多個子任務組。

9.根據權利要求1所述處理任務的方法，其特征在于，所述將所述子任務的信息存在子任務信息表中之后，還包括：

更新所述主任務的處理狀態。

10.根據權利要求1所述處理任務的方法，其特征在于，所述發送至分布式集群的子任務的執行狀態包括未開始且消息未下發。

11.根據權利要求1所述處理任務的方法，其特征在于，所述在所述子任務信息表中，通過主任務下屬子任務的執行狀態，周期性確定發送至分布式集群的子任務，包括：

在所述子任務信息表中，篩選出未執行子任務組，所述未執行子任務組的執行狀態包括未開始且消息未下發；

已下發子任務組的數量未超過預設分片閾值，則發送所述未執行子任務組至分布式集群，所述已下發子任務組與所述未執行子任務組屬于相同的主任務，所述未執行子任務組包括一個或多個未執行子任務。

12.根據權利要求11所述處理任務的方法，其特征在于，所述已下發子任務組與所述未執行子任務組并行處理。