解決的問題

當(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)的消息了。

網(wǎng)友評論