[發明專利]任務調度方法和裝置

有效

• 申請號: 201610074460.8
• 申請日: 2016-02-02
• 公開（公告）號: CN105786600B
• 公開（公告）日: 2019-05-03
• 發明（設計）人: 趙勇
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京英賽嘉華知識產權代理有限責任公司 11204
• 代理人: 王達佐;馬曉亞

1.一種任務調度方法，其特征在于，所述方法包括：

獲取任務和所有執行機的執行機信息，其中，所述執行機信息包括：工作狀態、任務信息、訪問狀態和使用率，所述執行機工作狀態包括：空閑和非空閑，所述執行機任務信息包括：未啟動任務數、正在執行任務數和排隊任務數，正在執行任務數與排隊任務數之和為啟動任務數，未啟動任務數與啟動任務數之和為總任務數；

根據所述所有執行機的任務信息將所述所有執行機的工作狀態標記為空閑或非空閑；

如果存在工作狀態為空閑的執行機，則：

獲取所有工作狀態為空閑的執行機的任務信息；

計算各工作狀態為空閑的執行機總任務數與所述各工作狀態為空閑的執行機最大并發量比值并排序，選取比值最小的工作狀態為空閑的執行機為最優執行機，其中，所述執行機最大并發量為所述執行機并行執行任務數的最大值；

如果不存在工作狀態為空閑的執行機，則：

獲取所述所有工作狀態為非空閑的執行機的任務信息；

計算各工作狀態為非空閑的執行機的啟動任務數與所述各工作狀態為非空閑的執行機最大并發量比值并排序，選取比值最小的工作狀態為非空閑的執行機為最優執行機；

將所述任務調度給所述最優執行機。

2.根據權利要求1所述的任務調度方法，其特征在于，所述獲取任務和所有執行機的執行機信息之前還包括：

生成任務并為所述任務分配執行機；

獲取所述執行機的任務信息；

如果所述執行機的啟動任務數小于所述執行機的最大并發量，則將所述任務直接在所述執行機執行。

3.根據權利要求1所述的任務調度方法，其特征在于，所述執行機訪問狀態包括：可訪問、不可訪問，所述獲取任務和所有執行機的執行機信息包括：

獲取任務；

獲取所有執行機的訪問狀態；

獲取所有訪問狀態為可訪問的執行機的執行機信息。

4.根據權利要求3所述的任務調度方法，其特征在于，所述使用率包括：CPU使用率和內存使用率，所述獲取所有執行機訪問狀態為可訪問的執行機的執行機信息包括：

獲取所有訪問狀態為可訪問的執行機的使用率；

獲取所有訪問狀態為可訪問的執行機中CPU使用率小于預設CPU使用率上限閾值并且內存使用率也小于預設內存使用率上限閾值的執行機的執行機信息。

5.根據權利要求1所述的任務調度方法，其特征在于，所述將所述任務調度給所述最優執行機之后，還包括：

接收所述最優執行機發送的回執信息并更新所述任務的任務完成狀態，其中所述回執信息包括：任務ID、執行機ID、任務完成狀態，所述任務完成狀態包括：已開始、排隊中或已完成。

6.根據權利要求5所述的任務調度方法，其特征在于，所述將所述任務調度給所述最優執行機包括：

如果所述最優執行機的啟動任務數小于所述最優執行機的最大并發量，則由所述最優執行機直接執行所述任務，并更新所述任務的任務完成狀態為已開始；

如果所述最優執行機的啟動任務數大于或等于所述最優執行機的最大并發量，則將所述任務調度到所述最優執行機的排隊任務中，并更新所述任務的任務完成狀態為排隊中；

如果所述任務已由所述最優執行機執行結束，則更新所述任務的任務完成狀態為已完成。