輕量級數(shù)據(jù)生產(chǎn)-消費(fèi)者模式處理方法、系統(tǒng)及存儲介質(zhì)

基本信息

申請?zhí)?/td> CN202111168008.5 申請日 -
公開（公告）號 CN113608899B 公開（公告）日 2021-12-17
申請公布號 CN113608899B 申請公布日 2021-12-17
分類號 G06F9/54;G06F9/50 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 伍千虎;李志鋼;黃堯;嚴(yán)俊蘭;李雄華;宋亞濤 申請（專利權(quán)）人 創(chuàng)智和宇信息技術(shù)股份有限公司
代理機(jī)構(gòu) 長沙知行亦創(chuàng)知識產(chǎn)權(quán)代理事務(wù)所（普通合伙） 代理人 嚴(yán)理佳
地址 410000 湖南省長沙市長沙高新開發(fā)區(qū)欣盛路159號
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種輕量級數(shù)據(jù)生產(chǎn)?消費(fèi)者模式處理方法、系統(tǒng)及計(jì)算機(jī)可讀存儲介質(zhì)。通過確定分發(fā)渠道中環(huán)形指針隊(duì)列存儲緩沖區(qū)的數(shù)量值S，以及每個(gè)存儲緩沖區(qū)的大小值K；根據(jù)數(shù)據(jù)分發(fā)器的數(shù)據(jù)分發(fā)規(guī)則，確定數(shù)據(jù)生產(chǎn)者產(chǎn)生的待寫入數(shù)據(jù)所應(yīng)分發(fā)至的目標(biāo)存儲緩存區(qū)；在消費(fèi)者線程大于所述K值時(shí)，將所述存儲緩沖區(qū)中的一個(gè)或多個(gè)存儲緩沖區(qū)分別劃分為多個(gè)部分緩存區(qū)，一個(gè)所述存儲緩沖區(qū)中的所述多個(gè)部分緩存區(qū)分別分配至不同的所述消費(fèi)者線程進(jìn)行消費(fèi)。無需復(fù)雜的調(diào)用流程，直接由分發(fā)渠道定義環(huán)形指針隊(duì)列buffer的數(shù)量和個(gè)數(shù)，無需設(shè)置消息隊(duì)列中間件，直接實(shí)現(xiàn)了數(shù)據(jù)包的生產(chǎn)?消費(fèi)處理，降低了數(shù)據(jù)量，實(shí)現(xiàn)輕量級的目的。