[發(fā)明專利]分布式任務調(diào)度的方法和裝置

有效

• 申請?zhí)枺?/td>: 201510312490.3
• 申請日: 2015-06-09
• 公開（公告）號: CN104915258B
• 公開（公告）日: 2019-07-02
• 發(fā)明（設計）人: 徐賢軍
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿(mào)易有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 中原信達知識產(chǎn)權代理有限責任公司 11219
• 代理人: 陳依虹;劉光明

1.一種分布式任務調(diào)度的方法，包括：

由分布式任務調(diào)度裝置接收任務執(zhí)行請求；

由所述裝置的控制器模塊確定線程池是否繁忙；

如果所述線程池空閑，則由所述控制器模塊處理接收到的任務執(zhí)行請求并對所述線程池生成任務線程；

由所述線程池執(zhí)行所生成的任務線程；以及

在所述任務完成之后，由所述裝置的參數(shù)設置模塊確定由所述線程池生成的執(zhí)行線程是否繼續(xù)執(zhí)行；

其中，在確定所述線程池是否繁忙之前，還包括：由所述控制器模塊確定是否校驗調(diào)度；所述校驗調(diào)度是指判斷所述線程池是否繁忙。

2.根據(jù)權利要求1所述的方法，其中，由所述線程池執(zhí)行所請求的任務進一步包括：

由所述參數(shù)設置模塊計算已執(zhí)行的總?cè)蝿諗?shù)；以及

由所述參數(shù)設置模塊將已執(zhí)行的總?cè)蝿諗?shù)與請求的總?cè)蝿諗?shù)進行比較，以便確定所述任務是否已經(jīng)執(zhí)行完成。

3.根據(jù)權利要求2所述的方法，進一步包括：

如果確定沒有完成所述任務，則由所述控制器模塊從任務池取出參數(shù)信息預設定的任務數(shù)；以及

由所述線程池執(zhí)行所取出的任務，直到所有任務都已經(jīng)執(zhí)行完成。

4.根據(jù)權利要求1所述的方法，進一步包括：

如果確定所述線程池所生成的執(zhí)行線程繼續(xù)執(zhí)行，則由所述控制器模塊獲取任務池中待執(zhí)行的任務數(shù)；

由所述控制器模塊確定所獲取的待執(zhí)行的任務數(shù)是否達到報警臨界值；以及

如果已經(jīng)達到所述報警臨界值，則由報警通知模塊執(zhí)行任務積壓報警。

5.一種分布式任務調(diào)度的裝置，包括：

控制器模塊，所述控制器模塊被配置成，當所述裝置接收到任務執(zhí)行請求時，確定線程池是否繁忙，并且在所述線程池空閑的情況下，處理接收到的任務執(zhí)行請求并對所述線程池生成任務線程；

線程池，所述線程池被配置成執(zhí)行所生成的任務線程；以及

參數(shù)設置模塊，所述參數(shù)設置模塊被配置成，在任務完成之后，確定由所述線程池生成的執(zhí)行線程是否繼續(xù)執(zhí)行；

其中，所述控制器進一步被配置成：

在確定所述線程池是否繁忙之前，確定是否校驗調(diào)度；所述校驗調(diào)度是指判斷所述線程池是否繁忙。

6.根據(jù)權利要求5所述的裝置，其中，所述參數(shù)設置模塊進一步被配置成：

計算已執(zhí)行的總?cè)蝿諗?shù)；以及

將已執(zhí)行的總?cè)蝿諗?shù)與請求的總?cè)蝿諗?shù)進行比較，以便確定所述任務是否已經(jīng)執(zhí)行完成。

7.根據(jù)權利要求6所述的裝置，其中，所述控制器進一步被配置成：如果確定沒有完成所述任務，則從任務池取出參數(shù)信息預設定的任務數(shù)。

8.根據(jù)權利要求7所述的裝置，其中，所述線程池進一步被配置成：執(zhí)行所取出的任務，直到所有任務都已經(jīng)執(zhí)行完成。

9.根據(jù)權利要求5所述的裝置，其中，所述控制器進一步被配置成：

如果確定所述線程池所生成的執(zhí)行線程繼續(xù)執(zhí)行，則獲取任務池中待執(zhí)行的任務數(shù)；以及

確定所獲取的待執(zhí)行的任務數(shù)是否達到報警臨界值。

10.根據(jù)權利要求9所述的裝置，進一步包括：

報警通知模塊，所述報警通知模塊被配置成，如果已經(jīng)達到所述報警臨界值，則執(zhí)行任務積壓報警。

11.一種分布式任務調(diào)度的電子設備，其特征在于，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執(zhí)行，使得所述一個或多個處理器實現(xiàn)如權利要求1-4中任一所述的方法。

12.一種計算機可讀介質(zhì)，其上存儲有計算機程序，其特征在于，所述程序被處理器執(zhí)行時實現(xiàn)如權利要求1-4中任一所述的方法。