[發(fā)明專利]任務(wù)的分配方法、裝置、電子設(shè)備、服務(wù)器及存儲介質(zhì)在審
| 申請?zhí)枺?/td> | 202010418539.4 | 申請日: | 2020-05-18 |
| 公開(公告)號: | CN111625329A | 公開(公告)日: | 2020-09-04 |
| 發(fā)明(設(shè)計(jì))人: | 王天舟;曹福祥;王至前 | 申請(專利權(quán))人: | 北京達(dá)佳互聯(lián)信息技術(shù)有限公司 |
| 主分類號: | G06F9/48 | 分類號: | G06F9/48 |
| 代理公司: | 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224 | 代理人: | 方高明 |
| 地址: | 100085 北京市海淀*** | 國省代碼: | 北京;11 |
| 權(quán)利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 任務(wù) 分配 方法 裝置 電子設(shè)備 服務(wù)器 存儲 介質(zhì) | ||
本公開關(guān)于一種任務(wù)的分配方法、裝置、電子設(shè)備、服務(wù)器及存儲介質(zhì)。所述方法包括:獲取待分配任務(wù)的任務(wù)標(biāo)識;在任務(wù)標(biāo)識、任務(wù)數(shù)目和線程池的映射關(guān)系中,查詢是否存在所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的第一線程池;如果不存在所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的第一線程池,則在預(yù)設(shè)的各線程池中,確定待執(zhí)行任務(wù)數(shù)目最小的第二線程池,在任務(wù)標(biāo)識、任務(wù)數(shù)目和線程池的映射關(guān)系中,添加所述待分配任務(wù)的任務(wù)標(biāo)識和所述第二線程池的映射關(guān)系,并將所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的任務(wù)數(shù)目置為1;將所述待分配任務(wù)分配至所述第二線程池。采用本公開可以防止出現(xiàn)線程池饑餓現(xiàn)象。
技術(shù)領(lǐng)域
本公開涉及計(jì)算機(jī)技術(shù)領(lǐng)域,尤其涉及一種任務(wù)的分配方法、裝置、電子設(shè)備、服務(wù) 器及存儲介質(zhì)。
背景技術(shù)
在任務(wù)調(diào)度時(shí),具有相同任務(wù)標(biāo)識的任務(wù)需要分配至同一線程池中,以保證具有相同 任務(wù)標(biāo)識的任務(wù)可以按照任務(wù)提交的順序串行執(zhí)行。
目前,在對任務(wù)進(jìn)行線程池分配時(shí),首先,將該任務(wù)的任務(wù)標(biāo)識按照線程池的數(shù)目進(jìn) 行取模運(yùn)算,得到余數(shù)。然后,將該任務(wù)分配至線程池標(biāo)識為該余數(shù)的線程池中。這樣,可以保證具有相同任務(wù)標(biāo)識的任務(wù)能夠分配至同一線程池。
然而,當(dāng)具有相同第一任務(wù)標(biāo)志的第一任務(wù)的數(shù)量較多時(shí),將導(dǎo)致該第一任務(wù)對應(yīng)的 線程池中,任務(wù)排隊(duì)嚴(yán)重。此時(shí),如果第二任務(wù)標(biāo)志(與第一任務(wù)標(biāo)志不同,但取模的余 數(shù)相同)的第二任務(wù)也被分配至該線程池中,則會導(dǎo)致該第二任務(wù)需要等待較長時(shí)間才能 夠被執(zhí)行,從而出現(xiàn)線程池饑餓現(xiàn)象。
發(fā)明內(nèi)容
本公開提供一種任務(wù)的分配方法、裝置、電子設(shè)備、服務(wù)器及存儲介質(zhì),以至少解決 相關(guān)技術(shù)中現(xiàn)線程池饑餓的問題。本公開的技術(shù)方案如下:
根據(jù)本公開實(shí)施例的第一方面,提供一種任務(wù)的分配方法,所述方法包括:
獲取待分配任務(wù)的任務(wù)標(biāo)識;
在任務(wù)標(biāo)識、任務(wù)數(shù)目和線程池的映射關(guān)系中,查詢是否存在所述待分配任務(wù)的任務(wù) 標(biāo)識對應(yīng)的第一線程池;
如果不存在所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的第一線程池,則在預(yù)設(shè)的各線程池中, 確定待執(zhí)行任務(wù)數(shù)目最小的第二線程池,在任務(wù)標(biāo)識、任務(wù)數(shù)目和線程池的映射關(guān)系中, 添加所述待分配任務(wù)的任務(wù)標(biāo)識和所述第二線程池的映射關(guān)系,并將所述待分配任務(wù)的任 務(wù)標(biāo)識對應(yīng)的任務(wù)數(shù)目置為1;
將所述待分配任務(wù)分配至所述第二線程池。
作為一種可選的實(shí)施方式,所述方法還包括:
如果存在所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的第一線程池,則在任務(wù)標(biāo)識、任務(wù)數(shù)目和 線程池的映射關(guān)系中,將所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的任務(wù)數(shù)目加1,并將所述待分 配任務(wù)分配至所述第一線程池。
作為一種可選的實(shí)施方式,所述方法還包括:
當(dāng)所述待分配任務(wù)執(zhí)行結(jié)束后,在任務(wù)標(biāo)識、任務(wù)數(shù)目和線程池的映射關(guān)系中,將所 述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的任務(wù)數(shù)目減1。
作為一種可選的實(shí)施方式,所述方法還包括:
如果所述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的任務(wù)數(shù)目為0,則在任務(wù)標(biāo)識、任務(wù)數(shù)目和線 程池的映射關(guān)系中,刪除所述待分配任務(wù)的任務(wù)標(biāo)識和所述第二線程池的映射關(guān)系。
根據(jù)本公開實(shí)施例的第二方面,提供一種任務(wù)的分配裝置,所述裝置包括:
獲取模塊,被配置為獲取待分配任務(wù)的任務(wù)標(biāo)識;
查詢模塊,被配置為在任務(wù)標(biāo)識、任務(wù)數(shù)目和線程池的映射關(guān)系中,查詢是否存在所 述待分配任務(wù)的任務(wù)標(biāo)識對應(yīng)的第一線程池;
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京達(dá)佳互聯(lián)信息技術(shù)有限公司,未經(jīng)北京達(dá)佳互聯(lián)信息技術(shù)有限公司許可,擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202010418539.4/2.html,轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- 任務(wù)協(xié)作裝置及方法
- 用于量化任務(wù)價(jià)值的任務(wù)管理方法及裝置
- 用于運(yùn)行任務(wù)的系統(tǒng)、方法和裝置
- 一種分布式任務(wù)調(diào)度系統(tǒng)及方法
- 任務(wù)信息處理方法
- 一種同步任務(wù)異步執(zhí)行的方法和調(diào)度系統(tǒng)
- 數(shù)據(jù)處理方法、裝置、電子設(shè)備及計(jì)算機(jī)可讀介質(zhì)
- 一種自動分配和推送的任務(wù)管理平臺及方法
- 程序執(zhí)行控制的裝置及方法、終端和存儲介質(zhì)
- 基于會話的任務(wù)待辦方法、系統(tǒng)、電子設(shè)備及存儲介質(zhì)





