[發明專利]一種分布式任務調度方法、裝置、計算機設備及存儲介質

在審

• 申請號: 202011621605.4
• 申請日: 2020-12-30
• 公開（公告）號: CN112650572A
• 公開（公告）日: 2021-04-13
• 發明（設計）人: 劉耀暉
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F16/27
• 代理公司: 深圳眾鼎專利商標代理事務所(普通合伙) 44325
• 代理人: 譚果林

本發明應用于分布式人工智能系統技術領域，公開了一種分布式任務調度方法、裝置、計算機設備及存儲介質，其中，方法部分包括：以預設頻率輪詢數據庫中的任務信息表，獲得調度任務信息以確定調度任務的任務類型，若任務類型為秒級任務，則生成秒級任務實例，確定秒級任務執行器并將秒級任務實例發送至秒級任務執行器，接收秒級任務執行器反饋的秒級任務執行信息，并更新任務信息表；本發明中，將需要即時執行的秒級任務直接分配給可用的任務執行器執行，提高了秒級任務的執行精確度，提高了秒級任務執行的效率，從而減少了出現任務阻塞的可能，進而提高了所有任務的執行效率。本申請還涉及區塊鏈技術領域，任務信息表等數據存儲于區塊鏈網絡中。

技術領域

本發明涉及分布式人工智能系統領域，尤其涉及一種分布式任務調度方法、裝置、計算機設備及存儲介質。

背景技術

當用戶使用應用程序，在使用過程中用戶可能會要應用程序提供某一服務，此時，管理應用程序的任務調度服務器就會自動形成一個任務。由于服務器管理多個應用程序，且使用應用程序的用戶較多，短時間內任務調度系統會根據用戶需求生成大量不同的任務，任務調度服務器需要對大量不同的任務進行配置任務隊列，以根據任務的先后以及任務的優先級安排任務的執行。

現有技術中，一般根據任務的執行時間將任務創建為定時任務，在生成定時任務的定時任務實例后，任務調度服務器使用CRON表達式初始化執行時間字段，保證每一定時任務實例都存在可用的下次調度時間，然后將定時任務實例推入時間輪，到達下次調度時間時則觸發任務，將定時任務實例分配給任務執行器。但是這種方法中，任務調度服務器會花費大量的時間在管理任務上，定時的任務觸發功能不夠精準，導致大量的任務無法得到有效執行，造成任務阻塞，降低了任務的執行效率。

發明內容

本發明提供一種分布式任務調度方法、裝置、計算機設備及存儲介質，以解決現有任務調度中，定時的任務觸發功能不夠精準導致任務的執行效率不高問題。

一種分布式任務調度方法，包括：

以預設頻率輪詢數據庫中的任務信息表，獲得各調度任務的調度任務信息；

根據所述調度任務信息確定所述調度任務的任務類型；

若所述任務類型為秒級任務，則根據所述秒級任務的調度任務信息生成秒級任務實例，所述秒級任務為需要即時執行的任務；

確定執行所述秒級任務實例的秒級任務執行器，并將所述秒級任務實例發送至所述秒級任務執行器，以使所述秒級任務執行器執行所述秒級任務實例；

接收所述秒級任務執行器反饋的秒級任務執行信息，并根據所述秒級任務執行信息更新所述任務信息表。

進一步地，所述根據所述調度任務信息確定所述調度任務的任務類型之后，所述方法還包括：

若所述任務類型為定時任務，則根據所述定時任務的調度任務信息生成定時任務實例，所述定時任務為需要以一定的時長間隔執行的任務，所述定時任務實例包括所述定時任務的下次執行時刻；

確定所述下次執行時刻是否在所述預設時刻之后；

若所述下次執行時刻在所述預設時刻之后，則將所述定時任務實例置入時間輪；

當所述時間輪的計時時刻達到所述下次執行時刻時，確定是否需要執行所述定時任務實例；

若需要執行所述定時任務實例，則確定執行所述定時任務實例的定時任務執行器，并將所述定時任務實例發送至定時任務執行器，以使所述定時任務執行器執行所述定時任務實例；

接收所述定時任務執行器反饋的定時任務執行信息，并根據所述定時任務執行信息更新所述任務信息表。

進一步地，所述確定是否需要執行所述定時任務實例，包括：

確定所述定時任務實例中的任務狀態是否為啟用狀態；

若所述定時任務實例中的任務狀態為所述啟用狀態，則確定為需要執行所述定時任務實例；

若所述定時任務實例中的任務狀態為非啟用狀態，確定為不需要執行所述定時任務實例。