[發明專利]任務處理方法及裝置

有效

• 申請號: 202010138709.3
• 申請日: 2020-03-03
• 公開（公告）號: CN111367637B
• 公開（公告）日: 2023-05-12
• 發明（設計）人: 賀財平
• 申請（專利權）人: 螞蟻勝信（上海）信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京智信禾專利代理有限公司 11637
• 代理人: 李曉慶

本說明書實施例提供的任務處理方法及裝置，其中所述方法包括：接收定時任務處理請求，并根據所述定時任務處理請求獲取待處理任務；獲取預設的響應時間數據庫中的下游系統處理上一次待處理任務的響應時間，并基于所述響應時間和權重計算所述待處理任務的預測并發量；基于所述預測并發量向所述下游系統發送業務請求，并接收所述下游系統返回的處理所述業務請求的處理結果，其中，所述業務請求中包括所述預測并發量對應的待處理任務。

技術領域

本說明書實施例涉及計算機技術領域，特別涉及一種任務處理方法。本說明書一個或者多個實施例同時涉及一種任務處理裝置，一種計算設備，以及一種計算機可讀存儲介質。

背景技術

在數據處理過程中，有一種服務可以稱為定時任務，即定時器觸發的接口調用請求。服務提供方在接收到上游系統請求時，對于時效性要求不高的請求，可以先落任務，返回受理成功，后通過定時器觸發執行，將最終的處理結果返回。定時器觸發任務執行時，為了提高吞吐量，一般會并發多線程的執行任務，如果任務需要依賴下游系統，那么并發數設置成多少，將直接影響著系統吞吐量。

現有技術中，定時任務在執行時，并發量通常是固定的，無法保證系統的吞吐量，影響網絡系統的數據傳輸處理效率，因此急需提供一種可以自適應的調整合適的并發量來提高任務的處理效率。

發明內容

有鑒于此，本說明書施例提供了一種任務處理方法。本說明書一個或者多個實施例同時涉及一種任務處理裝置，一種計算設備，以及一種計算機可讀存儲介質，以解決現有技術中存在的技術缺陷。

根據本說明書實施例的第一方面，提供了一種任務處理方法，包括：

接收定時任務處理請求，并根據所述定時任務處理請求獲取待處理任務；

獲取預設的響應時間數據庫中的下游系統處理上一次待處理任務的響應時間，并基于所述響應時間和權重計算所述待處理任務的預測并發量，其中，所述權重包括基于當前并發量以及所述下游系統處理上一次待處理任務的響應時間確定的權重；

基于所述預測并發量向所述下游系統發送業務請求，并接收所述下游系統返回的處理所述業務請求的處理結果，其中，所述業務請求中包括所述預測并發量對應的待處理任務。

可選的，所述基于所述響應時間和權重計算所述待處理任務的預測并發量包括：

基于所述響應時間和權重通過線性回歸算法計算所述待處理任務的預測并發量。

可選的，所述線性回歸算法對應的公式為：

f(x_i)＝w₀+w₁x₁+w₂x₂+…+w_ix_i

其中，f(x_i)表示預測并發量，w表示權重，x表示下游系統的響應時間。

可選的，所述接收所述下游系統返回的處理所述業務請求的處理結果包括：

接收所述下游系統返回的處理所述業務請求中所述預測并發量對應的待處理任務的處理結果。

可選的，所述接收所述下游系統返回的處理所述業務請求中所述預測并發量對應的待處理任務的處理結果之后，還包括：

記錄所述下游系統返回處理所述業務請求中所述預測并發量對應的待處理任務的處理結果時的返回時間，并基于所述返回時間確定所述下游系統處理所述業務請求中所述預測并發量對應的待處理任務的響應時間。

可選的，所述基于所述返回時間確定所述下游系統處理所述業務請求中所述預測并發量對應的待處理任務的響應時間之前，還包括：

獲取基于所述預測并發量向所述下游系統發送業務請求的發送時間。