[發明專利]多線程并發處理方法和多線程并發處理系統有效
| 申請號： | 201610143991.8 | 申請日： | 2016-03-14 |
| 公開（公告）號： | CN107193539B | 公開（公告）日： | 2020-11-24 |
| 發明（設計）人： | 周劍橋 | 申請（專利權）人： | 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司 |
| 主分類號： | G06F9/38 | 分類號： | G06F9/38;G06F9/50 |
| 代理公司： | 北京成創同維知識產權代理有限公司 11449 | 代理人： | 蔡純;張靖琳 |
| 地址： | 100080 北京市海淀區杏石口路6*** | 國省代碼： | 北京;11 |
| 權利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關鍵詞： | 多線程 并發 處理 方法 系統 | ||
1.一種多線程并發處理方法，包括：
接收線程接收多個待處理數據，并發送給分發線程；
所述分發線程將所述待處理數據分配給多個處理線程；
每一所述處理線程將所述待處理數據進行處理后，將已處理數據發送給匯聚線程；
所述匯聚線程按照所述分發線程分發的順序從所述多個處理線程中依次接收所述已處理數據進行匯總，
其中，所述多線程并發處理方法帶有時序功能；
所述接收線程、所述分發線程、多個所述處理線程和所述匯聚線程并發執行。
2.根據權利要求1所述的多線程并發處理方法，其中，所述接收線程和所述分發線程將所述待處理數據存儲到數據通道，每一所述處理線程將所述已處理數據存儲到數據通道，所述分發線程和所述處理線程從所述數據通道中讀取所述待處理數據，所述匯聚線程從所述數據通道中讀取所述已處理數據。
3.根據權利要求2所述的多線程并發處理方法，其中，所述數據通道包括：消息隊列、共享內存和異步IO。
4.根據權利要求2所述的多線程并發處理方法，其中，如果所述匯聚線程從一個所述數據通道中無法讀取到數據，阻塞預定時間后，按照分發的順序讀取下一個所述數據通道內的數據。
5.根據權利要求1所述的多線程并發處理方法，其中，所述分發線程將所述待處理數據分配給多個處理線程包括：
所述分發線程讀取N*M條所述待處理數據；
按順序將N*M條的所述待處理數據的每M條分別分配給N個所述處理線程，以此類推,
所述匯聚線程按照所述分發線程分發的順序從所述多個處理線程中依次接收所述已處理數據包括：
所述匯聚線程按照分發的順序分別從N個所述處理線程中的一個讀取M條所述已處理數據，以此類推，其中M大于等于1，N為大于等于2的整數。
6.根據權利要求1所述的多線程并發處理方法，還包括：在所述分發線程將所述待處理數據分配給多個處理線程前，對所述待處理數據進行排序。
7.根據權利要求1所述的多線程并發處理方法，還包括：在所述分發線程將所述待處理數據分配給多個處理線程前，所述分發線程通過所述待處理數據的自增型主鍵與所述處理線程的個數進行取模運算，以確定所述分發線程分發的順序。
8.一種多線程并發處理系統，包括：接收線程、分發線程、多個處理線程和匯聚線程，其中，所述多線程并發處理系統帶有時序功能；
所述接收線程用于接收多個待處理數據并發送給所述分發線程；
所述分發線程用于將所述待處理數據分配給多個處理線程；
每一所述處理線程用于將所述待處理數據進行處理后，將已處理數據發送給匯聚線程；
所述匯聚線程用于按照所述分發線程分發的順序從所述多個處理線程中接收所述已處理數據進行匯總，
所述接收線程、所述分發線程、多個所述處理線程和所述匯聚線程為并發執行的線程。
9.根據權利要求8所述的多線程并發處理系統，還包括：數據通道，所述接收線程、所述分發線程、多個所述處理線程和所述匯聚線程通過所述數據通道進行數據傳輸。
10.根據權利要求9所述的多線程并發處理系統，其中，所述數據通道包括：消息隊列、共享內存和異步IO。
11.根據權利要求9所述的多線程并發處理系統，所述匯聚線程還包括：容錯單元，如果所述匯聚線程從一個所述數據通道中無法讀取數據，阻塞預定時間后，按照分發的順序讀取下一個數據通道內的數據。
該專利技術資料僅供研究查看技術是否侵權等信息，商用須獲得專利權人授權。該專利全部權利屬于北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司，未經北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司許可，擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作，請聯系【客服】
本文鏈接：http://www.17sss.com.cn/pat/books/201610143991.8/1.html，轉載請聲明來源鉆瓜專利網。
- 上一篇：一種改進的鉤取技術的方法及裝置
- 下一篇：一種應用軟件演示方法、裝置
