[發(fā)明專利]一種基于lookup操作的多線程消息處理方法在審
| 申請?zhí)枺?/td> | 202010469760.2 | 申請日： | 2020-05-28 |
| 公開（公告）號： | CN111737026A | 公開（公告）日： | 2020-10-02 |
| 發(fā)明（設(shè)計）人： | 李偉;李雪生 | 申請（專利權(quán)）人： | 蘇州浪潮智能科技有限公司 |
| 主分類號： | G06F9/54 | 分類號： | G06F9/54;G06F16/182 |
| 代理公司： | 濟南舜源專利事務(wù)所有限公司 37205 | 代理人： | 孫玉營 |
| 地址： | 215100 江蘇省蘇州市吳*** | 國省代碼： | 江蘇;32 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 一種 基于 lookup 操作 多線程 消息 處理 方法 | ||
1.一種基于lookup操作的多線程消息處理方法，其特征在于，包括：
獲取分布式文件系統(tǒng)需進行l(wèi)ookup處理操作的消息隊列；
在所述消息隊列中增加lookup消息處理線程池，設(shè)置達到所述線程池處理消息的最低處理量；
遍歷消息隊列，并根據(jù)所述最低處理量篩選出待處理消息隊列；
將待處理消息隊列中的lookup類型消息平均分配給所述線程池的線程，線程池中的多個線程同時處理所述lookup類型消息。
2.根據(jù)權(quán)利要求1所述的一種基于lookup操作的多線程消息處理方法，其特征在于，所述遍歷消息隊列，并根據(jù)所述最低處理量篩選出待處理消息隊列，包括：
配置當(dāng)前處理消息之后第M個消息為所述起始位置；
從起始位置開始遍歷當(dāng)前消息隊列，將連續(xù)屬于lookup類型的消息數(shù)量達到最少處理量的消息作為待處理消息隊列。
3.根據(jù)權(quán)利要求1所述的一種基于lookup操作的多線程消息處理方法，其特征在于，所述方法還包括：
在所述待處理消息隊列的起點插入一個自定義類型消息；
監(jiān)控所述自定義類型消息的處理狀態(tài)：當(dāng)所述自定義類型消息被處理時，暫停原有消息處理線程，線程池中的多個線程同時處理所述lookup類型消息。
4.根據(jù)權(quán)利要求3所述的一種基于lookup操作的多線程消息處理方法，其特征在于，所述方法還包括：
增加一個新的線程，所述新的線程用于處理所述自定義類型消息。
5.根據(jù)權(quán)利要求1所述的一種基于lookup操作的多線程消息處理方法，其特征在于，所述方法還包括：
各線程處理完成后單獨向上層模塊返回處理結(jié)果。
6.根據(jù)權(quán)利要求1所述的一種基于lookup操作的多線程消息處理方法，其特征在于，在所述消息隊列中增加lookup消息處理線程池，包括：
增加一個線程池，所述線程池用于處理消息隊列中的lookup類型消息；
并設(shè)置所述線程池默認(rèn)休眠狀態(tài)；
打開所述線程池中所有的線程執(zhí)行文件中l(wèi)ookup類型消息處理的權(quán)限。
7.根據(jù)權(quán)利要求1所述的一種基于lookup操作的多線程消息處理方法，其特征在于，所述方法還包括：
當(dāng)所述lookup消息處理線程池中所有的消息都處理完成后，所述線程池進入休眠狀態(tài)。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于蘇州浪潮智能科技有限公司，未經(jīng)蘇州浪潮智能科技有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.17sss.com.cn/pat/books/202010469760.2/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- 多線程應(yīng)用系統(tǒng)的異常處理方法和異常處理裝置
- 一種面向片上網(wǎng)絡(luò)的多線程調(diào)度實現(xiàn)方法
- 基于計算機多線程多核顯微鏡細胞圖像快速掃描處理方法
- 一種基于同步鎖的多線程處理方法、終端以及存儲介質(zhì)
- 多線程并發(fā)處理系統(tǒng)及方法
- 海外控股估值流程控制方法、裝置、計算機設(shè)備及存儲介質(zhì)
- 讀數(shù)方法、電子裝置、計算機設(shè)備及存儲介質(zhì)
- 一種基于云平臺多線程調(diào)度的方法、系統(tǒng)、設(shè)備及介質(zhì)
- 一種基于云平臺的前端多線程調(diào)度方法和系統(tǒng)
- 多線程調(diào)度方法、裝置、電子設(shè)備及存儲介質(zhì)
