[發(fā)明專利]一種任務(wù)的調(diào)度方法及相關(guān)裝置

在審

• 申請?zhí)枺?/td>: 201811158291.1
• 申請日: 2018-09-30
• 公開（公告）號: CN109302477A
• 公開（公告）日: 2019-02-01
• 發(fā)明（設(shè)計）人: 周志剛
• 申請（專利權(quán)）人: 武漢斗魚網(wǎng)絡(luò)科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F9/52;G06F9/50;G06F9/48
• 代理公司: 北京眾達(dá)德權(quán)知識產(chǎn)權(quán)代理有限公司 11570
• 代理人: 徐松

本發(fā)明實施例公開了一種任務(wù)的調(diào)度方法及相關(guān)裝置，用于提高任務(wù)調(diào)度的效率。本發(fā)明實施例方法包括：主機器接收圖片識別請求，圖片識別請求用于請求識別圖片；主機器將圖片識別請求進行轉(zhuǎn)換，得到識別任務(wù)，并將識別任務(wù)放入識別隊列；當(dāng)調(diào)度識別隊列中的當(dāng)前任務(wù)時，主機器根據(jù)當(dāng)前系統(tǒng)時間得到隨機數(shù)；主機器根據(jù)隨機數(shù)和副機器的個數(shù)，在副機器中確定目標(biāo)副機器，主機器為多臺機器中的任一臺機器，副機器為多臺機器中除主機器以外的其他機器，主機器用于管理副機器；主機器將當(dāng)前任務(wù)調(diào)度給目標(biāo)副機器，以使得目標(biāo)副機器執(zhí)行當(dāng)前任務(wù)。

技術(shù)領(lǐng)域

本發(fā)明涉及開發(fā)平臺領(lǐng)域，尤其涉及一種任務(wù)的調(diào)度方法及相關(guān)裝置。

背景技術(shù)

對于直播平臺來說，需要對直播平臺所直播的內(nèi)容進行審核，以確認(rèn)直播的內(nèi)容是正規(guī)合法的內(nèi)容，而不能是色情直播。現(xiàn)有技術(shù)中，確認(rèn)直播的內(nèi)容是否正規(guī)合法，可以通過鑒黃服務(wù)框架的機器來進行識別。而實際應(yīng)用中，對于鑒黃服務(wù)框架來說，當(dāng)直播間同時開播數(shù)量比較多時會造成用于鑒別是否違規(guī)的請求非常多，并且很有可能同一時間的請求量非常大，這樣會導(dǎo)致很多請求超時得不到處理。

那么基于有多臺識別服務(wù)機器的鑒黃服務(wù)框架來說，如何合理的設(shè)計使得所有的請求任務(wù)不會造成超時或者丟棄，是一個急需解決的問題。

發(fā)明內(nèi)容

本發(fā)明實施例提供了一種任務(wù)的調(diào)度方法及相關(guān)裝置，用于提高任務(wù)調(diào)度的效率。

本發(fā)明實施例的第一方面提供了一種任務(wù)的調(diào)度方法，包括：主機器接收圖片識別請求，所述圖片識別請求用于請求識別圖片；所述主機器將所述圖片識別請求進行轉(zhuǎn)換，得到識別任務(wù)，并將所述識別任務(wù)放入識別隊列；當(dāng)調(diào)度所述識別隊列中的當(dāng)前任務(wù)時，所述主機器根據(jù)當(dāng)前系統(tǒng)時間得到隨機數(shù)；所述主機器根據(jù)所述隨機數(shù)和副機器的個數(shù)，在所述副機器中確定目標(biāo)副機器，所述主機器為多臺機器中的任一臺機器，所述副機器為所述多臺機器中除所述主機器以外的其他機器，所述主機器用于管理所述副機器；所述主機器將所述當(dāng)前任務(wù)調(diào)度給所述目標(biāo)副機器，以使得所述目標(biāo)副機器執(zhí)行所述當(dāng)前任務(wù)。

在一種可能的實施例中，所述主機器將所述圖片識別請求進行轉(zhuǎn)換，得到識別任務(wù)：所述主機器通過調(diào)用系統(tǒng)函數(shù)Struct Task將所述圖片識別請求轉(zhuǎn)換為所述識別任務(wù)，所述識別任務(wù)的識別分?jǐn)?shù)用于表示所述識別圖片的識別結(jié)果。

在一種可能的實施例中，所述方法還包括：所述主機器定義存儲接口和刪除接口，所述存儲接口用于在所述識別隊列中插入任務(wù)，所述刪除接口用于在所述識別隊列中刪除任務(wù)。

在一種可能的實施例中，所述主機器定義存儲接口和刪除接口包括：所述主機器定義自動鎖對象，所述自動鎖對象用于進行多線程的同步互斥；所述主機器將所述自動鎖對象傳入互斥變量wirte_mutex；所述主機器調(diào)用接口push_back將所述任務(wù)存入到所述任務(wù)隊列的尾端；所述主機器取出所述任務(wù)隊列的頭端的任務(wù)；所述主機器調(diào)用接口pop_front將所述任務(wù)隊列的頭端的任務(wù)刪除。

在一種可能的實施例中，所述主機器根據(jù)當(dāng)前系統(tǒng)時間得到隨機數(shù)包括：所述主機器調(diào)用函數(shù)Time()獲取所述當(dāng)前系統(tǒng)時間；所述主機器將所述當(dāng)前系統(tǒng)時間作為函數(shù)Rand()的輸入以得到所述隨機數(shù)。

在一種可能的實施例中，所述方法還包括：所述主機器通過String函數(shù)設(shè)計內(nèi)存數(shù)據(jù)結(jié)構(gòu)，并通過標(biāo)準(zhǔn)模板庫STL的list鏈表存儲所述內(nèi)存數(shù)據(jù)結(jié)構(gòu)，所述內(nèi)存數(shù)據(jù)結(jié)構(gòu)用于管理所述副機器的注冊和注銷，所述內(nèi)存數(shù)據(jù)結(jié)構(gòu)包括所述副機器的編號，所述副機器的IP地址和所述副機器的名稱。

在一種可能的實施例中，所述主機器根據(jù)所述隨機數(shù)和所述副機器的個數(shù)，在所述副機器中確定目標(biāo)副機器包括：所述主機器根據(jù)所述隨機數(shù)據(jù)中和所述副機器的個數(shù)進行求余計算，得到余數(shù)；所述主機器在所述副機器中確定編碼為所述余數(shù)的目標(biāo)副機器。