變化單個生產者單個消費者的問題

Question

我有這樣的情況：

一個單一的生產者執行很多的數據庫查詢 - 結果發送的消息，併到達了單個消費者的隊列（郵件沒有到達特殊訂單）

另一方面 - 單個消費者讀取這些消息，並且只在所有消息到達時纔開始處理消息。

解決這類問題的最好方法是什麼？

謝謝！

Answer 1

是否有特殊的原因延遲處理，直到所有人都到達？

我過去使用得相當成功的一種方法是將消息出隊並將消息中的相關數據和序列號保存到本地存儲中。此外，隨着每封郵件的到達，我會增加收到的郵件數量以及存儲期望的郵件總數。最後，所有消息都已到達，增量計數器等於預期的消息數量，我執行實際工作。

通過這種方式，我們能夠接收到所有消息，但只能根據您的要求執行實際工作。