解決的問題
當(dāng)我們有多個消息的生產(chǎn)者線程,一個消費(fèi)者線程時,他們之間如何進(jìn)行高并發(fā)、線程安全的協(xié)調(diào)?
很簡單,用一個隊列。
當(dāng)我們有多個消息的生產(chǎn)者線程,多個消費(fèi)者線程,并且每一條消息需要被所有的消費(fèi)者都消費(fèi)一次(這就不是一般隊列,只消費(fèi)一次的語義了),該怎么做?
這時仍然需要一個隊列。但是:
1. 每個消費(fèi)者需要自己維護(hù)一個指針,知道自己消費(fèi)了隊列中多少數(shù)據(jù)。這樣同一條消息,可以被多個人獨立消費(fèi)。
2. 隊列需要一個全局指針,指向最后一條被所有生產(chǎn)者加入的消息。消費(fèi)者在消費(fèi)數(shù)據(jù)時,不能消費(fèi)到這個全局指針之后的位置——因為這個全局指針,已經(jīng)是代表隊列中最后一條可以被消費(fèi)的消息了。