[發(fā)明專利]一種數(shù)據(jù)流體系結(jié)構(gòu)中動態(tài)節(jié)點分配方法和系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201710681320.1
• 申請日: 2017-08-10
• 公開（公告）號: CN107632890B
• 公開（公告）日: 2021-03-02
• 發(fā)明（設(shè)計）人: 歐焱;張浩;李易;譚旭;葉笑春
• 申請（專利權(quán)）人: 北京中科睿芯科技集團有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/52
• 代理公司: 北京科龍寰宇知識產(chǎn)權(quán)代理有限責任公司 11139
• 代理人: 孫皓晨

1.一種數(shù)據(jù)流體系結(jié)構(gòu)中動態(tài)節(jié)點分配方法，其特征在于，包括以下步驟：

將數(shù)據(jù)流圖中的節(jié)點一一映射到物理執(zhí)行單元上，其中，該步驟中被映射的節(jié)點稱為死節(jié)點，未映射的節(jié)點和死節(jié)點中沒有被完全利用的節(jié)點稱為活節(jié)點，其中，沒有被完全利用的節(jié)點指節(jié)點對應(yīng)的物理執(zhí)行單元的計算資源沒有被完全利用，每一活節(jié)點均預(yù)設(shè)有一租用期限；

在數(shù)據(jù)流圖中設(shè)置一管理節(jié)點，管理節(jié)點與每一節(jié)點之間均具有一數(shù)據(jù)傳輸通路；

在管理節(jié)點設(shè)置一信息表，將活節(jié)點統(tǒng)計在所述信息表中，每一活節(jié)點對應(yīng)于所述信息表中的一個條目，每一條目包括活節(jié)點ID、活節(jié)點被租用狀態(tài)ST、活節(jié)點剩余空間大小RV以及活節(jié)點距離租用期限的時間RT；

為每一死節(jié)點分別設(shè)置一擁塞閾值；

檢測死節(jié)點是否擁塞，如果死節(jié)點檢測上游節(jié)點已執(zhí)行完畢但是其自身的指令仍正在執(zhí)行，并且執(zhí)行時間超過其對應(yīng)的擁塞閾值，則判定死節(jié)點已發(fā)生擁塞；

當一死節(jié)點A發(fā)生擁塞時，死節(jié)點A則向所述管理節(jié)點發(fā)送一請求消息；

管理節(jié)點收到請求消息后，首先在所述信息表中搜索是否有能夠滿足請求消息的需求的活節(jié)點，如果沒有則將該請求消息調(diào)換至消息隊列末尾，如果有能夠滿足請求消息的需求的一活節(jié)點B，則向該活節(jié)點B發(fā)送一租用消息并將請求消息映射至該活節(jié)點B上，設(shè)置一map節(jié)點作為死節(jié)點A和該活節(jié)點B的前驅(qū)節(jié)點，設(shè)置一merge節(jié)點作為死節(jié)點A和該活節(jié)點B的后續(xù)節(jié)點，該map節(jié)點和該merge節(jié)點均用于將前驅(qū)節(jié)點的數(shù)據(jù)分發(fā)給后續(xù)節(jié)點，該活節(jié)點B開始累計租用時間；

當該活節(jié)點B的租用時間達到租用期限時，管理節(jié)點向該活節(jié)點B發(fā)出一回收請求，若死節(jié)點A需要繼續(xù)租用該活節(jié)點B，則死節(jié)點A向管理節(jié)點發(fā)送一續(xù)租消息，該管理節(jié)點向該活節(jié)點B發(fā)出確認續(xù)租消息或不再續(xù)租消息，若死節(jié)點A不需要繼續(xù)租用該活節(jié)點B，則該活節(jié)點B向管理節(jié)點發(fā)送一反饋消息并關(guān)閉自身的數(shù)據(jù)輸入端口直至該活節(jié)點B中的數(shù)據(jù)完全執(zhí)行完畢并且流出之后，管理節(jié)點接收到該活節(jié)點B發(fā)送的反饋消息后修改該活節(jié)點B在所述信息表中的活節(jié)點被租用狀態(tài)ST。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)流體系結(jié)構(gòu)中動態(tài)節(jié)點分配方法，其特征在于，所述管理節(jié)點具有一消息隊列，于所述消息隊列中，消息優(yōu)先級由高至低分別為：反饋消息-續(xù)租消息-請求消息，所述管理節(jié)點于每一時間拍檢測并處理所述消息隊列中的消息。

3.根據(jù)權(quán)利要求1所述的數(shù)據(jù)流體系結(jié)構(gòu)中動態(tài)節(jié)點分配方法，其特征在于，在所述信息表的活節(jié)點被租用狀態(tài)ST這一條目中，活節(jié)點已被租用用0表示，活節(jié)點未被租用用1表示，已被租用的活節(jié)點在接收到回收請求后用2表示，以及已被租用的活節(jié)點在被續(xù)租后用2表示。

4.一種數(shù)據(jù)流體系結(jié)構(gòu)中動態(tài)節(jié)點分配系統(tǒng)，其特征在于，該系統(tǒng)包括一個或多個存儲器以及一個或多個處理器，處理器用于執(zhí)行存儲器中存儲的計算機程序指令，以執(zhí)行權(quán)利要求1-3中任一項所述的數(shù)據(jù)流體系結(jié)構(gòu)中動態(tài)節(jié)點分配方法。