[發(fā)明專利]一種在多核DSP下的海量數(shù)據(jù)流多模態(tài)調(diào)度方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710509588.7
• 申請(qǐng)日: 2017-06-28
• 公開（公告）號(hào): CN107608784B
• 公開（公告）日: 2020-06-09
• 發(fā)明（設(shè)計(jì)）人: 江磊;劉從新;李申
• 申請(qǐng)（專利權(quán)）人: 西安微電子技術(shù)研究所
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F9/54
• 代理公司: 西安通大專利代理有限責(zé)任公司 61200
• 代理人: 徐文權(quán)

1.一種在多核DSP下的海量數(shù)據(jù)流多模態(tài)調(diào)度方法，其特征在于，包括主控核和加速核，所述主控核和加速核之間通過請(qǐng)求包隊(duì)列傳輸請(qǐng)求，基于數(shù)據(jù)維度和數(shù)據(jù)優(yōu)先順序，確定連續(xù)選擇、隨機(jī)選擇和螺旋選擇三種數(shù)據(jù)塊選擇方法，根據(jù)負(fù)載均衡確定數(shù)據(jù)塊循環(huán)調(diào)度和數(shù)據(jù)塊負(fù)載均衡調(diào)度兩種數(shù)據(jù)塊多核分配方法，對(duì)通過數(shù)據(jù)塊分組方法根據(jù)分配粒度選定的數(shù)據(jù)塊加載多個(gè)計(jì)算核中進(jìn)行處理；

在多核DSP下的海量數(shù)據(jù)流多模態(tài)調(diào)度方法主要在主控核實(shí)現(xiàn)，具體流程如下：

S101、用戶根據(jù)需求設(shè)置數(shù)據(jù)塊的調(diào)度組合方式和分配粒度；

S102、用戶在分割數(shù)據(jù)塊時(shí)，根據(jù)調(diào)度方式將數(shù)據(jù)塊分配至不同的隊(duì)列；

S103、當(dāng)數(shù)據(jù)塊分割完成后，若系統(tǒng)設(shè)置了數(shù)據(jù)塊選擇方式，則根據(jù)選擇的調(diào)度方式調(diào)整數(shù)據(jù)塊的順序，并根據(jù)不同的數(shù)據(jù)塊分配方式加入相應(yīng)的調(diào)度隊(duì)列中；

S104、在數(shù)據(jù)塊開始調(diào)度后，根據(jù)不同的數(shù)據(jù)塊分配和分組方式，從不同的調(diào)度隊(duì)列中取出數(shù)據(jù)塊并分配至加速核處理；

數(shù)據(jù)塊連續(xù)選擇方法為數(shù)據(jù)塊連續(xù)調(diào)度順序調(diào)整主要針對(duì)每個(gè)核上處理的數(shù)據(jù)塊順序，即每個(gè)核的數(shù)據(jù)塊號(hào)是連續(xù)的，具體的調(diào)整步驟為：

S201、按照任務(wù)設(shè)定的數(shù)據(jù)塊分組大小，計(jì)算數(shù)據(jù)塊的組數(shù)，判斷數(shù)據(jù)塊分組是否合理；

S202、計(jì)算每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)和剩余數(shù)據(jù)塊個(gè)數(shù)；

S203、判斷數(shù)據(jù)塊的綁定個(gè)數(shù)是否大于1，若小于1跳轉(zhuǎn)至S205；

S204、根據(jù)綁定大小，修正每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)和剩余數(shù)據(jù)塊個(gè)數(shù)；

S205、判斷臨時(shí)數(shù)據(jù)塊隊(duì)列中是否還有剩余的數(shù)據(jù)塊，若有跳轉(zhuǎn)至S206；否則結(jié)束調(diào)整；

S206、從臨時(shí)數(shù)據(jù)塊隊(duì)列中取出數(shù)據(jù)塊；

S207、判斷數(shù)據(jù)塊的分配類型，若為循環(huán)分配類型，調(diào)整至S208；若為負(fù)載均衡分配類型調(diào)整至S213；

S208、判斷剩余的數(shù)據(jù)塊個(gè)數(shù)是否大于零，且當(dāng)前數(shù)據(jù)塊個(gè)數(shù)是否等于每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)加上綁定大小，若滿足，則跳轉(zhuǎn)至S209；

S209、當(dāng)前核數(shù)據(jù)塊分配完畢，將核號(hào)修改為下一個(gè)核號(hào)，修改剩余數(shù)據(jù)塊的大小，同時(shí)將當(dāng)前數(shù)據(jù)個(gè)數(shù)塊置零；

S210、判斷剩余的數(shù)據(jù)塊個(gè)數(shù)是否小于等于0，且當(dāng)前數(shù)據(jù)塊個(gè)數(shù)是否等于每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)，若滿足，則跳轉(zhuǎn)至S211；

S211、當(dāng)前核數(shù)據(jù)塊分配完畢，將核號(hào)修改為下一個(gè)核號(hào)，同時(shí)將當(dāng)前數(shù)據(jù)塊個(gè)數(shù)置為零；

S212、將數(shù)據(jù)塊添加至當(dāng)前核的加速核調(diào)度隊(duì)列，并增加當(dāng)前數(shù)據(jù)塊個(gè)數(shù)，跳轉(zhuǎn)至S205；

S213、將數(shù)據(jù)塊直接添加至全局的數(shù)據(jù)塊調(diào)度隊(duì)列，跳轉(zhuǎn)至S205；

所述數(shù)據(jù)塊隨機(jī)選擇方法為數(shù)據(jù)塊隨機(jī)調(diào)度順序調(diào)整主要針對(duì)整體的調(diào)度順序，首先按照隨機(jī)的順序從臨時(shí)調(diào)度隊(duì)列中取出數(shù)據(jù)塊，然后再將其插入相應(yīng)的調(diào)度隊(duì)列中，具體的調(diào)整步驟為：

S301、按照任務(wù)設(shè)定的數(shù)據(jù)塊分組大小，計(jì)算數(shù)據(jù)塊的組數(shù)，判斷數(shù)據(jù)塊分組是否合理

S302、設(shè)置隨機(jī)閾值，計(jì)算每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)和剩余數(shù)據(jù)塊個(gè)數(shù)；

S303、判斷數(shù)據(jù)塊的綁定個(gè)數(shù)是否大于1，若大于1調(diào)整至S304；

S304、根據(jù)綁定大小，重新設(shè)置隨機(jī)閾值，計(jì)算每個(gè)核均勻分配的綁定個(gè)數(shù)和剩余綁定個(gè)數(shù)；

S305、判斷臨時(shí)數(shù)據(jù)塊隊(duì)列中是否還有剩余的數(shù)據(jù)塊，若由調(diào)整至S306；否則結(jié)束調(diào)整

S306、根據(jù)隨機(jī)閾值，獲取一個(gè)隨機(jī)的數(shù)據(jù)塊索引；

S307、判斷當(dāng)前綁定個(gè)數(shù)是否大于1，若大于則跳轉(zhuǎn)至S308；否則跳轉(zhuǎn)至S317；

S308、根據(jù)綁定大小計(jì)算當(dāng)前的數(shù)據(jù)塊的索引號(hào)，從臨時(shí)數(shù)據(jù)塊隊(duì)列中取出所有的綁定數(shù)據(jù)塊；

S309、判斷數(shù)據(jù)塊的分配類型，若為循環(huán)分配類型，調(diào)整至S310；若為負(fù)載均衡分配類型調(diào)整至S315；

S310、判斷剩余的綁定個(gè)數(shù)是否大于零，且當(dāng)前綁定個(gè)數(shù)是否等于每個(gè)核均勻分配的綁定個(gè)數(shù)加上1，若滿足，則跳轉(zhuǎn)至S311；

S311、當(dāng)前核數(shù)據(jù)塊分配完畢，將核號(hào)修改為下一個(gè)核號(hào)，修改剩余綁定大小，同時(shí)將當(dāng)前綁定個(gè)數(shù)塊置零；

S312、判斷當(dāng)前綁定個(gè)數(shù)是否小于等于0，且當(dāng)前綁定個(gè)數(shù)是否等于每個(gè)核均勻分配的綁定個(gè)數(shù)，若滿足，則跳轉(zhuǎn)至S311；

S313、當(dāng)前核數(shù)據(jù)塊分配完畢，將核號(hào)修改為下一個(gè)核號(hào)，同時(shí)將當(dāng)前綁定個(gè)數(shù)置為零；

S314、將數(shù)據(jù)塊添加至當(dāng)前核的加速核調(diào)度隊(duì)列，跳轉(zhuǎn)至S316；

S315、將數(shù)據(jù)塊直接添加至全局的數(shù)據(jù)塊調(diào)度隊(duì)列；

S316、從臨時(shí)隊(duì)列中刪除所有綁定的數(shù)據(jù)塊，修改隨機(jī)閾值，跳轉(zhuǎn)至S305；

S317、直接從臨時(shí)隊(duì)列中取出數(shù)據(jù)塊；

S318、判斷數(shù)據(jù)塊的分配類型，若為循環(huán)分配類型，調(diào)整至S319、；若為負(fù)載均衡分配類型調(diào)整至S323；

S319、判斷剩余的數(shù)據(jù)塊個(gè)數(shù)是否大于零，且當(dāng)前數(shù)據(jù)塊個(gè)數(shù)是否等于每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)加上1，若滿足，則跳轉(zhuǎn)至S320；

S320、當(dāng)前核數(shù)據(jù)塊分配完畢，將核號(hào)修改為下一個(gè)核號(hào)，修改剩余數(shù)據(jù)塊的大小，同時(shí)將當(dāng)前數(shù)據(jù)個(gè)數(shù)塊置零；

S321、判斷當(dāng)前數(shù)據(jù)塊個(gè)數(shù)是否小于等于0，且當(dāng)前數(shù)據(jù)塊個(gè)數(shù)是否等于每個(gè)核均勻分配的數(shù)據(jù)塊個(gè)數(shù)，若滿足，則跳轉(zhuǎn)至S322；

S322、當(dāng)前核數(shù)據(jù)塊分配完畢，將核號(hào)修改為下一個(gè)核號(hào)，同時(shí)將當(dāng)前數(shù)據(jù)塊個(gè)數(shù)置為零；

S323、將數(shù)據(jù)塊添加至當(dāng)前核的加速核調(diào)度隊(duì)列，并增加當(dāng)前數(shù)據(jù)塊個(gè)數(shù)；

S324、將數(shù)據(jù)塊直接添加至全局的數(shù)據(jù)塊調(diào)度隊(duì)列；

S325、從臨時(shí)數(shù)據(jù)塊隊(duì)列中刪除數(shù)據(jù)塊，修改隨機(jī)閾值，跳轉(zhuǎn)至S305。