生產者/消費者 - 生產者增加了數據收集不阻塞，從消費者的消費收集數據批量

Question

我有一個生產者/消費者用例，這是一個有點不尋常。 我有一些真正的世界用例，我希望他們能夠在不阻塞的情況下將對象添加到集合中。 消費者（只有一個）應該阻塞，直到集合中有一定數量的對象可用（例如500），然後大量消費它們。雖然少於500個，它應該阻止並等待收集填充。我不介意隊列超過這個值（700，1000等）很短的時間。

我目前似乎還沒有找到一個解決方案來解決這個確切的問題。 我在考慮使用ConcurrentLinkedQueue並讓消費者定期檢查隊列是否有足夠的數據，但這似乎相當起反作用。

另一個想法是使用LinkedBlockingQueue。生產者不會阻塞（除非隊列已滿，這意味着它具有Integer.MAX_VALUE值 - 這不是我的情況，所以它都很好）。消費者將執行queue.take（）並將元素添加到內部集合中。當內部收集達到500個元素時，它將批量使用它們。

您有任何提示嗎？

謝謝！

Answer 1

最後我去了LinkedBlockingQueue。

生產者將項目添加到隊列中。

消費者將做queue.poll（），並保持物品進入內部集合。當內部收集達到500個元素時，它將大量消耗它們。我也可以設置一些超時。例如，如果X秒過去了，即使它的項目數少於所需的數量（例如220），我也會使用該集合。

Answer 2

你可以簡單地引入一箇中間隊列和消費/製造商，這將得到由生產者充滿了隊列中的項目，將它們存儲在一個列表，一旦列表大小是500，放列表本身在隊列由消費者閱讀。消費者會阻止下一個有500件物品的清單。

當然你也可以封裝這個邏輯由生產者共享的對象中：生產者自己的項目添加到「配料機」的對象。批處理對象將項目添加到專用列表中，一旦列表大小爲500，批處理將該列表添加到隊列中。只要確保batcher的addItem（）方法是同步的。這將避免額外的線程和隊列。