Многопоточность: 1 отправитель, N получателей

mport java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Scanner;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
 
public class NQueue {
    private LinkedList<String> queue;  // arrays of queus
    private CountDownLatch countDownLatch;
 
    public NQueue() {
        queue = new LinkedList<String>();
    }
 
    public synchronized boolean add(String s) {
        if (s == null) {
            return false;
        }
        notify();
        return queue.add(s);  // add last;
    }
 
    public synchronized String remove() throws InterruptedException {
        if (queue.isEmpty()) {
            return null;
        }
        wait();
        return queue.remove();  // remove first
    }
 
    public static void main(String[] args) {
        ExecutorService exec = Executors.newCachedThreadPool();
 
        int n = 10; // число потоков приемников
        List<RunReceive> list = new ArrayList<>();
 
        for (int i = 0; i < n; i++) {
            RunReceive receiver = new RunReceive();
            list.add(receiver);
        }
 
        exec.execute(new RunSource(list));  // source запускаем с списком приемников
        for (int i = 0; i < n; i++) {
            exec.execute(list.get(i));
        }
 
        System.out.println("To exit press e");
        Scanner in = new Scanner(System.in);
        while (true) {
            if (in.hasNext() && in.next().equals("e")) {
                exec.shutdownNow();
                break;
            }
        }
 
        System.out.println("System shutdown");
 
    }
}

import java.util.Random;
 
 
public class RunReceive implements Runnable {
    private static Random rnd = new Random();
    private static int counter = 0;
    private final int id = counter++;
    private final NQueue queue;
 
    public RunReceive() {
        queue = new NQueue();
    }
 
    public synchronized NQueue getQueue() {  // вернуть свою очередь
        return queue;
    }
    @Override
    public void run() {
        try {
            while (!Thread.interrupted()) {
                System.out.println(this + " get " + queue.remove());
                Thread.sleep(rnd.nextInt(500) + 50); // 50..500
            }
        } catch (InterruptedException e) {
            System.out.println(this + "interrupted");
 
        }
        System.out.println(this + "finished");
    }
 
    @Override
    public String toString() {
        return "RunReceive: " + id + " ";
    }
}

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
 
public class RunSource implements Runnable {
    private static Random rnd = new Random();
    private List<NQueue> list;
 
    /**
     * Constructor
     */
    public RunSource(List<RunReceive> receivers) {
        list = new ArrayList<>();
        for (RunReceive receiver : receivers) {
            list.add(receiver.getQueue());
        }
    }
 
    private String getMessage() {
        int n = rnd.nextInt(100);
        return "message: " + n;
    }
 
    @Override
    public void run() {
        int n = 0;
        while (!Thread.interrupted()) {
            try {
                String s = getMessage();
                for (NQueue queue : list) {
                    queue.add(s); // сгенерили сообщение
                }
                System.out.println("added: " + s);
 
                n++;
                if (n > 10) {
                    break;
                }
                // nQueue.remove(); // удаляем сообщение
 
                Thread.sleep(rnd.nextInt(500) + 50);  // 50..500 ms
 
            } catch (InterruptedException e) {
                System.out.println(this + " interrupted");
            }
 
            System.out.println(this + "exited");
 
        }
 
 
    }
 
    @Override
    public String toString() {
        return "RunSource ";
    }
 
}