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

在審

• 申請號: 201810460659.3
• 申請日: 2018-05-15
• 公開（公告）號: CN110489224A
• 公開（公告）日: 2019-11-22
• 發明（設計）人: 王宇
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 11219 中原信達知識產權代理有限責任公司
• 代理人: 張一軍;張效榮<國際申請>=<國際公布>

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

確定任務執行器，發送工作量計算指令至每個任務執行器；

接收每個任務執行器所反饋的結果值，確定每個任務執行器反饋結果值所需的時間，以計算每個任務執行器的工作效率；其中，所述結果值與所述工作量計算指令相應；

確定待處理的任務量，根據每個任務執行器的工作效率，進行任務量分配。

2.根據權利要求1所述的方法，其特征在于，所述確定每個任務執行器反饋結果值所需的時間，以計算每個任務執行器的工作效率包括：

確定每個任務執行器反饋結果值所需的時間，統計所有任務執行器反饋結果值的總時間，計算每個任務執行器的工作量證明值；其中，工作量證明值＝所有任務執行器的總時間/單個任務執行器的時間；

根據每個任務執行器的工作量證明值，確定所有任務執行器的總工作量證明值，計算每個任務執行器的工作效率；其中，工作效率＝單個任務執行器的工作量證明值/所有任務執行器的總工作量證明值。

3.根據權利要求1所述的方法，其特征在于，所述接收每個任務執行器所反饋的結果值，確定每個任務執行器反饋結果值所需的時間還包括：

接收每個任務執行器所反饋的結果值，基于預定的驗證規則對所反饋的結果值進行驗證，剔除結果值不符合所述驗證規則的任務執行器；以及

確定每個任務執行器反饋結果值所需的時間，基于預定時間閾值對所確定的時間進行篩選，剔除時間超出所述預定時間閾值的任務執行器。

4.根據權利要求1所述的方法，其特征在于，所述確定待處理的任務量，根據每個任務執行器的工作效率，進行任務量分配包括：

接收新分配的任務量，獲取每個任務執行器當前未處理的任務量，得到所述待處理的任務量；

根據所述待處理的任務量、每個任務執行器的工作效率以及當前未處理的任務量，確定所述新分配的任務量中分配至每個任務執行器的任務量。

5.根據權利要求1所述的方法，其特征在于，所述發送工作量計算指令至每個任務執行器包括：

當達到預定更新周期時，發送所述工作量計算指令至每個任務執行器。

6.一種任務調度的裝置，其特征在于，包括：

指令發送模塊，用于確定任務執行器，發送工作量計算指令至每個任務執行器；

效率計算模塊，用于接收每個任務執行器所反饋的結果值，確定每個任務執行器反饋結果值所需的時間，以計算每個任務執行器的工作效率；其中，所述結果值與所述工作量計算指令相應；

任務分配模塊，用于確定待處理的任務量，根據每個任務執行器的工作效率，進行任務量分配。

7.根據權利要求6所述的裝置，其特征在于，所述效率計算模塊，用于：

確定每個任務執行器反饋結果值所需的時間，統計所有任務執行器反饋結果值的總時間，計算每個任務執行器的工作量證明值；其中，工作量證明值＝所有任務執行器的總時間/單個任務執行器的時間；

根據每個任務執行器的工作量證明值，確定所有任務執行器的總工作量證明值，計算每個任務執行器的工作效率；其中，工作效率＝單個任務執行器的工作量證明值/所有任務執行器的總工作量證明值。

8.根據權利要求6所述的裝置，其特征在于，所述效率計算模塊，用于：

接收每個任務執行器所反饋的結果值，基于預定的驗證規則對所反饋的結果值進行驗證，剔除結果值不符合所述驗證規則的任務執行器；以及

確定每個任務執行器反饋結果值所需的時間，基于預定時間閾值對所接收的時間進行篩選，剔除時間超出所述預定時間閾值的任務執行器。

9.根據權利要求6所述的裝置，其特征在于，所述任務分配模塊，用于：

接收新分配的任務量，獲取每個任務執行器當前未處理的任務量，得到所述待處理的任務量；

根據所述待處理的任務量、每個任務執行器的工作效率以及當前未處理的任務量，確定所述新分配的任務量中分配至每個任務執行器的任務量。