解決的問(wèn)題
當(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)一次的語(yǔ)義了),該怎么做?
這時(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)的消息了。