解決的問題
當(dāng)我們有多個(gè)消息的生產(chǎn)者線程，一個(gè)消費(fèi)者線程時(shí)，他們之間如何進(jìn)行高并發(fā)、線程安全的協(xié)調(diào)？
很簡(jiǎn)單，用一個(gè)隊(duì)列。
當(dāng)我們有多個(gè)消息的生產(chǎn)者線程，多個(gè)消費(fèi)者線程，并且每一條消息需要被所有的消費(fèi)者都消費(fèi)一次（這就不是一般隊(duì)列，只消費(fèi)一次的語義了），該怎么做？
這時(shí)仍然需要一個(gè)隊(duì)列。但是：
1. 每個(gè)消費(fèi)者需要自己維護(hù)一個(gè)指針，知道自己消費(fèi)了隊(duì)列中多少數(shù)據(jù)。這樣同一條消息，可以被多個(gè)人獨(dú)立消費(fèi)。
2. 隊(duì)列需要一個(gè)全局指針，指向最后一條被所有生產(chǎn)者加入的消息。消費(fèi)者在消費(fèi)數(shù)據(jù)時(shí)，不能消費(fèi)到這個(gè)全局指針之后的位置——因?yàn)檫@個(gè)全局指針，已經(jīng)是代表隊(duì)列中最后一條可以被消費(fèi)的消息了。
延伸閱讀
- ssh框架 2016-09-30
- 阿里移動(dòng)安全 [無線安全]玩轉(zhuǎn)無線電——不安全的藍(lán)牙鎖 2017-07-26
- 消息隊(duì)列NetMQ 原理分析4-Socket、Session、Option和Pipe 2024-03-26
- Selective Search for Object Recognition 論文筆記【圖片目標(biāo)分割】 2017-07-26
- 詞向量-LRWE模型-更好地識(shí)別反義詞同義詞 2017-07-26
- 從棧不平衡問題 理解 calling convention 2017-07-26
- php imagemagick 處理 圖片剪切、壓縮、合并、插入文本、背景色透明 2017-07-26
- Swift實(shí)現(xiàn)JSON轉(zhuǎn)Model - HandyJSON使用講解 2017-07-26
- 阿里移動(dòng)安全 Android端惡意鎖屏勒索應(yīng)用分析 2017-07-26
- 集合結(jié)合數(shù)據(jù)結(jié)構(gòu)來看看(二) 2017-07-26
學(xué)習(xí)是年輕人改變自己的最好方式