解決的問題

當我們有多個消息的生產(chǎn)者線程,一個消費者線程時,他們之間如何進行高并發(fā)、線程安全的協(xié)調(diào)?

很簡單,用一個隊列。

 

當我們有多個消息的生產(chǎn)者線程,多個消費者線程,并且每一條消息需要被所有的消費者都消費一次(這就不是一般隊列,只消費一次的語義了),該怎么做?

這時仍然需要一個隊列。但是:

1. 每個消費者需要自己維護一個指針,知道自己消費了隊列中多少數(shù)據(jù)。這樣同一條消息,可以被多個人獨立消費。

2. 隊列需要一個全局指針,指向最后一條被所有生產(chǎn)者加入的消息。消費者在消費數(shù)據(jù)時,不能消費到這個全局指針之后的位置——因為這個全局指針,已經(jīng)是代表隊列中最后一條可以被消費的消息了。

延伸閱讀

學習是年輕人改變自己的最好方式-Java培訓,做最負責任的教育,學習改變命運,軟件學習,再就業(yè),大學生如何就業(yè),幫大學生找到好工作,lphotoshop培訓,電腦培訓,電腦維修培訓,移動軟件開發(fā)培訓,網(wǎng)站設(shè)計培訓,網(wǎng)站建設(shè)培訓學習是年輕人改變自己的最好方式