gistfile1.txt

import java.util.*;

public class QueueModel {

    public static void main(String[] args) {
        Queue<String> queue = new LinkedList<>();
        QueueMessageProducer producer = new QueueMessageProducer(queue);

        List<QueueConsumer> consumers = new ArrayList<>();

        for (int i = 0; i < 3; i++ ) {
            QueueConsumer consumer = new QueueConsumer(
                    "Consumer"  + i,
                    queue
            );
            consumer.start();

            consumers.add(consumer);
        }

        Scanner scanner = new Scanner(System.in);

        while(true) {
            String message = scanner.nextLine();
            producer.notify(message);
        }
    }

    static class QueueMessageProducer {

        private Queue<String> queue;

        public QueueMessageProducer(Queue<String> queue) {
            this.queue = queue;
        }

        public void notify(String message) {
            synchronized (queue) {
                queue.add(message);
                queue.notifyAll();
            }
        }

    }

    static class QueueConsumer extends Thread {

        private Queue<String> queue;

        public QueueConsumer(String name, Queue<String> queue) {
            super(name);
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                while (true) {
                    synchronized (queue) {
                        if (!queue.isEmpty()) {
                            String message = queue.poll();
                            System.out.printf(
                                    "%s: Consuming message: %s%n", getName(), message
                            );

                            queue.notifyAll();
                        }
                    }

                    //Thread.sleep(500);
                }
            } catch (Exception e) {
                System.out.println("Exception occured: " + e.toString());
            }
        }

    }
}