[發明專利]任務的處理方法、裝置和服務器

有效

• 申請號: 201911035713.0
• 申請日: 2019-10-29
• 公開（公告）號: CN110737534B
• 公開（公告）日: 2021-05-25
• 發明（設計）人: 李感恩
• 申請（專利權）人: 京東數字科技控股有限公司
• 主分類號: G06F9/52
• 分類號: G06F9/52;G06F9/50
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 張曉霞;劉芳

1.一種任務的處理方法，其特征在于，應用于第三方集群服務器，所述第三方集群服務器上安裝有分布式任務調度系統，所述分布式任務調度系統用于統一調度多個節點設備的線程池，所述多個節點設備中每一個節點設備的線程池中均包括多個線程，在進行分布式任務調度服務時，所述方法包括：

檢測所述分布式阻塞隊列當前的隊列長度；

根據所述當前的隊列長度，確定所述分布式阻塞隊列可再容納任務的任務標識或任務對象；

接收任務請求；所述任務請求中包括待處理的一個或者多個任務的任務標識或任務對象；

將所述一個或者多個任務的任務標識或任務對象添加在分布式阻塞隊列中；

在接收數據請求時，將所述分布式阻塞隊列中最靠前的目標任務的任務標識或任務對象發送給所述多個節點設備的線程池中最先搶占任務的目標線程，以通過所述目標線程處理所述目標任務。

2.根據權利要求1所述的方法，其特征在于，所述分布式調度系統包括：線程池生產者，所述線程池生產者用于創建任務標識或任務對象，并通過所述任務請求將所述任務標識或所述任務對象發送給所述第三方集群服務器，所述方法還包括：

在所述分布式阻塞隊列可再容納任務的任務標識或任務對象時，接收每一個節點設備上報的線程池中線程的狀態信息；所述狀態信息為空閑狀態或者忙碌狀態；

若所述線程池中存在狀態信息為空閑狀態的第一線程，且所述第一線程的空閑時長大于預設閾值時，銷毀所述第一線程。

3.根據權利要求1所述的方法，其特征在于，所述方法還包括：

在確定所述分布式阻塞隊列無法再容納任務的任務標識或任務對象時，停止接收任務請求，直至所述分布式阻塞隊列中有任務被處理，且所述分布式阻塞隊列可再容納任務的任務標識或任務對象。

4.根據權利要求3所述的方法，其特征在于，所述方法還包括：

在所述分布式阻塞隊列無法再容納任務的任務標識或任務對象時，接收每一個節點設備上報的線程池中線程的狀態信息；所述狀態信息為空閑狀態或者忙碌狀態；

在接收到新的任務請求時，若所述線程池中每一個線程的狀態信息均為忙碌狀態，則向所述每一個節點設備發送指示信息，所述指示信息用于指示所述每一個節點設備在所述線程池中增加新的線程。

5.根據權利要求1-4任一項所述的方法，其特征在于，所述將所述分布式阻塞隊列中最靠前的目標任務的任務標識或任務對象發送給所述多個節點設備的線程池中最先搶占任務的目標線程，包括：

將序列化邏輯處理后的目標任務的任務標識或任務對象發送給所述多個節點設備的線程池中最先搶占任務的目標線程。

6.一種任務的處理裝置，其特征在于，應用于第三方集群服務器，所述第三方集群服務器上安裝有分布式任務調度系統，所述分布式任務調度系統用于統一調度多個節點設備的線程池，所述多個節點設備中每一個節點設備的線程池中均包括多個線程，在進行分布式任務調度服務時，所述裝置包括：

接收單元，用于接收任務請求；所述任務請求中包括待處理的一個或者多個任務的任務標識或任務對象；

處理單元，用于將所述一個或者多個任務的任務標識或任務對象添加在分布式阻塞隊列中；

發送單元，用于在接收數據請求時，將所述分布式阻塞隊列中最靠前的目標任務的任務標識或任務對象發送給所述多個節點設備的線程池中最先搶占任務的目標線程，以通過所述目標線程處理所述目標任務；

所述處理單元，還用于檢測所述分布式阻塞隊列當前的隊列長度；并根據所述當前的隊列長度，確定所述分布式阻塞隊列可再容納任務的任務標識或任務對象。