[發明專利]一種基于隊列的云平臺任務分配方法

有效

• 申請號: 201710396757.0
• 申請日: 2017-05-31
• 公開（公告）號: CN107301085B
• 公開（公告）日: 2020-10-23
• 發明（設計）人: 汪深海
• 申請（專利權）人: 樹根互聯技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/52
• 代理公司: 成都魚爪智云知識產權代理有限公司 51308
• 代理人: 代述波

1.一種基于隊列的云平臺任務分配方法，所述隊列包括用于存儲云平臺中所有任務的資源任務隊列和用于存儲節點的任務的節點任務隊列，其中，每一個所述節點均對應一個所述節點任務隊列，所述方法包括：

任務接收線程接收用戶提交的請求并將所述請求以任務的形式放入資源任務隊列；

任務調度線程從所述資源任務隊列調取第一任務，并根據所述第一任務的操作節點將所述第一任務放入對應的節點任務隊列；

任務分發線程從所述節點任務隊列取出所述第一任務并將所述第一任務分發到所述第一任務的操作節點以執行所述第一任務；

當所述任務調度線程從所述資源任務隊列調取所述第一任務時，所述資源任務隊列可以繼續放入其他任務，但不能被繼續調取任務；當被調取的所述第一任務完成后，所述資源任務隊列可以被繼續調取其他任務；

節點任務隊列包含計數器，當任務分發線程從節點任務隊列取出一個任務后，所述計數器會自動增加一個直至達到上限值；當計數器達到上限值時，節點任務隊列進入半凍結狀態，此時，該節點任務隊列可以被繼續放入其他任務，但不能被讀取下一任務。

2.如權利要求1所述的基于隊列的云平臺任務分配方法，其特征在于：當取出的任務被執行完成后，所述計數器的值會減少，此時所述節點任務隊列可以繼續被讀取其他任務。

3.一種基于隊列的云平臺任務分配管理系統，采用如權利要求1的一種基于隊列的云平臺任務分配方法,所述隊列包括資源任務隊列和節點任務隊列，所述資源任務隊列用于存儲云平臺中的所有任務，所述節點任務隊列用于存儲該節點的所有任務，其特征在于，

所述云平臺任務分配管理系統包括：

任務接收線程，用于接收用戶提交的請求并將所述請求以任務的形式放入所述資源任務隊列里；

任務調度線程，用于從所述資源任務隊列調取第一任務，并根據所述第一任務的操作節點將所述第一任務放入對應的所述節點任務隊列；

任務分發線程，用于從所述節點任務隊列取出所述第一任務并將所述第一任務分發到所述第一任務的操作節點以執行所述第一任務。