[發明專利]一種服務于多網格接入的集群任務調度管理器

無效

• 申請號: 201010510414.0
• 申請日: 2010-10-18
• 公開（公告）號: CN101958808A
• 公開（公告）日: 2011-01-26
• 發明（設計）人: 柴亞輝;劉覺夫;涂春萍;趙海霞;劉美香;謝昕
• 申請（專利權）人: 華東交通大學
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L12/56
• 代理公司: 南昌市平凡知識產權代理事務所 36122
• 代理人: 姚伯川

1.一種服務于多網格接入的集群任務調度管理器，其特征在于：所述服務于多網格接入的集群任務調度管理器包括任務分類與任務優先級劃分策略、本地任務的資源預約占用策略和任務的調度與資源分配策略。

2.根據權利要求1所述的一種服務于多網格接入的集群任務調度管理器，其特征在于，所述任務分類與任務優先級劃分策略為：

任務首先為分本地提交任務LT與網格提交任務GT；其中GT又根據集群接入的網格的不同分為某網格的GT(G1)、GT(G2)、……、GT(GN)；

任務的優先級P為P_LT＞P_GT(G1)＞P_GT(G2)＞……＞P_GT(GN)；

當集群系統內的本地用戶通過集群本地任務管理系統向集群提交任務時，則該任務為本地提交任務LT，如果該用戶通過網格來提交該任務時，則如果該任務向集群申請資源時，被認為是該網格的任務GT。

3.根據權利要求1所述的一種服務于多網格接入的集群任務調度管理器，其特征在于，所述本地任務的資源預約占用策略為：

本地任務LT為了能確保在任務提交時能夠及時獲得集群上的資源，可以對集群資源進行預約占用，預約占用的有效期為時間T_P；

預約占用的作用范圍只針對于網格任務，即：當用戶為本地任務LT預約占用資源R_P以后，該資源R_P在預約占用時間有效期內，網格任務無法使用該資源，但其它本地任務LT’可以使用該資源R_P；

用戶提交預約占用請求時，提交的信息包括：任務所需要的資源信息集合、預約有效期、預約用戶信息；

預約占用請求提交成功以后，如果當前的集群中的空閑資源能夠滿足用戶的資源預約占用需求，則預約占用管理器給用戶立即返回預約成功消息，并為用戶保留好預約的資源；

如果當前沒有滿足預約條件的資源，則預約占用管理器將暫存該預約請求，每當集群上資源有變化時，就進行預約占用請求，直到在預約請求時間有效期內，如果預約成功，向用戶返回預約成功消息，否則，在預約占用有效時間截止時返回預約失敗的信息。

4.根據權利要求1所述的一種服務于多網格接入的集群任務調度管理器，其特征在于，所述任務的調度與資源分配策略為：

假設初始時，沒有任務提交，當有新的任務提交時，轉第0步；

第0步：任務調度管理器的任務接收端口接收所有提交請求任務，并將其交給任務接收器，任務接收器將任務進行接收，如果在某一時刻，同時有來自不同的網格的任務同時提交，則需要根據每個任務優先級將這些任務按優先級高低進行排隊，首先對優先級最高的任務進行調度與資源分配；

第1步：從提交任務隊列出取出一個任務T_R，查看其所需要的資源，從集群的空閑資源管理器中尋找滿足其需求的資源，如果滿足其資源需求，則轉第2步，否則轉第3步；

第2步：如果該任務是本地任務LT，則為其分配資源，并更新當前集群空閑資源庫，轉第4步；否則，該任務為網格提交任務GT，先為其預約好其所需要的資源，并更新當前集群空閑資源庫，并確認該任務是否要提交到該集群，如果確認提交，轉第4步，否則轉第5步；

第3步：確認該任務是否需要加入該集群的等待再次提交任務隊列Q_W，如果確認加入Q_W，轉第6步；否則，取消該任務的提交，轉第7步；

第4步：將該任務交由任務狀態管理器來監控任務的提交狀態，并由任務提交管理器負責對該任務在集群上進行提交，轉第7步；

第5步：回收為該任務預留的資源，并更新當前集群空閑資源庫，轉第7步；

第6步：根據該任務的優先級確定任務要插入到Q_W中的位置；Q_W的排隊策略如下：

對于相同優先級的任務，提交時間在先的排在隊列的前面；

對于不同優先級的任務，則高優先級的任務排在低優先級的任務的前面，轉第7步；

第7步：查看當前提交任務隊列是否為空，如果該隊列為空，則轉第8步；否則，指向隊列的下一個任務，轉第1步；

第8步：查看當前有無空閑資源變化，如果空閑資源發生變化，則查看是Q_W否為空，

如果Q_W為空，則等待新任務到來，在新的任務到來之后，轉第1步；如果Q_W不為空，則轉第9步；

第9步：從Q_W中取出當前指針指向的任務，為其匹配空閑資源，

如果匹配成功，則提交該任務，轉第10步；如果資源匹配不成功，則指針指向Q_W中下一個任務，并轉第9步；

第10步：確認Q_W是否為空，

如果Q_W為空，則等待新任務提交或者空閑資源發生變化，轉第11步；

如果Q_W不為空，則指針指向Q_W中下一個任務，并轉第9步；

第11步：如果是有新的任務提交，則轉第0步，如果是空閑資源發生變化，則轉第8步。