LMAX Disruptor—多生產者多消費者中,消息複製分發的高性能實現

解決的問題 當我們有多個消息的生產者線程,一個消費者線程時,他們之間如何進行高併發、線程安全的協調? 很簡單,用一個隊列。   當我們有多個消息的生產者線程,多個消費者線程,並且每一條消息需要被所有的消費者都消費一次(這就不是一般隊列,只消費一次的語義了),該怎麼做? 這時仍然需要一個隊列。但是: 1. 每個消費者需要自己維護一個指針,知道自己消費了隊列中多少數據。這樣同一條消息,可以被多個人獨立
相關文章
相關標籤/搜索