Java Multiple Producer и Multiple с одной очередью в Java?

Question

У меня есть три источника P1, P2, P3 и три потребителя с одной общей очередью.Производитель P1 помещает / вставляет X1, X2, X3 в очередь, и его должны использовать только Потребитель C1, а не другие Потребители (C2, C3).В основном потребители C1 должны потреблять только значения, вставленные источником P1.это же правило относится и к остальным потребителям.C2-> P2 и C3-> P3.Как решить эту проблему в Java.

Answer 1

То, как это в конечном итоге сработает, будет существовать такой класс

class Envelope<S, T, M> {
    final S sender;
    final T topic;
    final M message;
    ...
};

Все отправленные сообщения будут обернуты в него (как настоящие письма в конвертах) и отправлены в MailBox,Диспетчер на другом конце почтового ящика просматривает поля темы / получателя конверта и применяет требуемую политику для доставки правильному получателю в правильном контексте (нить).

Что касается его кодирования самостоятельно - ясделал бы это только для удовольствия.Если бы мне что-то нужно быстро, я бы взял Akka, в котором уже есть все необходимые примитивы, и использовал их.