[發明專利]基于延遲隊列實現的統一計時服務方法和裝置

在審

• 申請號: 202011609304.X
• 申請日: 2020-12-30
• 公開（公告）號: CN114691310A
• 公開（公告）日: 2022-07-01
• 發明（設計）人: 吳茂昌;徐正禮
• 申請（專利權）人: 北京易掌云峰科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/54
• 代理公司: 北京戈程知識產權代理有限公司 11314
• 代理人: 程偉;甄雁翔

1.一種基于延遲隊列實現的統一計時服務方法，其特征在于，所述統一計時服務方法包括：

當接收到需要計時的業務服務請求時，創建需要計時的任務；

創建延遲隊列，將需要計時的任務放入創建的延遲隊列中，通過所述延遲隊列來維護需要計時的任務的列表；

創建守護線程來監聽延遲隊列中到期的需要計時的任務，以獲取要處理的需要計時的任務；

創建任務執行線程池，以將要處理的需要計時的任務放入所述任務執行線程池中；

通知相應的業務邏輯處理的服務，以進行后續的業務邏輯處理。

2.根據權利要求1所述的基于延遲隊列實現的統一計時服務方法，其特征在于，

放入創建的延遲隊列中的需要計時的任務包括：需要計時的任務的唯一標識符、需要計時的任務的執行時間戳和需要計時的任務與后續的業務邏輯處理相關的信息。

3.根據權利要求2所述的基于延遲隊列實現的統一計時服務方法，其特征在于，

在通過所述延遲隊列來維護需要計時的任務的列表時，需要計時的任務按需要計時的任務的執行時間戳自動排序，最先執行的任務優先排序到延遲隊列的起始；

每當新的需要計時的任務放入延遲隊列時，需要計時的任務的列表按照需要計時的任務的執行時間戳進行重新自動排序。

4.根據權利要求1所述的基于延遲隊列實現的統一計時服務方法，其特征在于，

所述任務執行線程池以多線程并發地處理要處理的需要計時的任務。

5.根據權利要求2所述的基于延遲隊列實現的統一計時服務方法，其特征在于，

在通知相應的業務邏輯處理的服務時，將需要計時的任務與后續的業務邏輯處理相關的信息傳遞給業務邏輯處理的服務。

6.根據權利要求2所述的基于延遲隊列實現的統一計時服務方法，其特征在于，

在將需要計時的任務放入創建的延遲隊列中時，將創建的需要計時的任務進行保存；

當計時服務出現異常時，讀取保存的需要計時的任務，判斷保存的需要計時的任務在當前時間點是否到期；

如果保存的需要計時的任務在當前時間點沒有到達執行時間戳，則將保存的需要計時的任務放入延遲隊列中；

如果保存的需要計時的任務在當前時間點已超過執行時間戳，則將保存的需要計時的任務刪除。

7.一種計算機可讀存儲介質，其上存儲有計算機程序，當所述計算機程序被處理器執行時實現根據權利要求1至6中任一項所述的方法。

8.一種基于延遲隊列實現的統一計時服務裝置，其特征在于，包括：

任務建立模塊，其配置為：當接收到需要計時的業務服務請求時，創建需要計時的任務；

延遲隊列模塊，其配置為：創建延遲隊列，將需要計時的任務放入創建的延遲隊列中，通過所述延遲隊列來維護需要計時的任務的列表；

守護線程模塊，其配置為：創建守護線程來監聽延遲隊列中到期的需要計時的任務，以獲取要處理的需要計時的任務；

任務執行線程池模塊，其配置為：創建任務執行線程池，以將要處理的需要計時的任務放入所述任務執行線程池中；

通知模塊，其配置為：通知相應的業務邏輯處理的服務，以進行后續的業務邏輯處理。

9.根據權利要求8所述的基于延遲隊列實現的統一計時服務裝置，其特征在于，

放入創建的延遲隊列中的需要計時的任務包括：需要計時的任務的唯一標識符、需要計時的任務的執行時間戳和需要計時的任務與后續的業務邏輯處理相關的信息；

所述延遲隊列模塊配置為：在通過所述延遲隊列來維護需要計時的任務的列表時，需要計時的任務按需要計時的任務的執行時間戳自動排序，最先執行的任務優先排序到延遲隊列的起始；每當新的需要計時的任務放入延遲隊列時，需要計時的任務的列表按照需要計時的任務的執行時間戳進行重新自動排序。

10.根據權利要求8所述的基于延遲隊列實現的統一計時服務裝置，其特征在于，

所述任務執行線程池模塊配置為：所述任務執行線程池以多線程并發地處理要處理的需要計時的任務；

所述通知模塊配置為：在通知相應的業務邏輯處理的服務時，將需要計時的任務與后續的業務邏輯處理相關的信息傳遞給業務邏輯處理的服務。