которые помещают свои сообщения в ограниченную очередь. Если места в очереди нет, они ждут, пока место не появится. Несколько потоков -потребителей должны все прочесть каждое из сообщений. Когда сообщение прочитано всеми потребителями, оно удаляется из очереди.
через реббит можно
очередь с количеством текущих потребителей у элемента очереди счетчик прочтений, когда достигает значения выше, элемент удаляется
О мне как то раз такую задачку на java давали
ConcurrentQueue
Обсуждают сегодня