gistfile1.java

import java.util.Random;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class Demo {

    private static final Random R = new Random();

    static class Producer implements Runnable {

        private final BlockingQueue<Integer> queue;

        Producer(BlockingQueue<Integer> queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                while (true) {
                    queue.put(R.nextInt());
                }
            } catch (InterruptedException ie) {
                System.err.println("Shutting down producer");
            }
        }
    }

    static class Consumer implements Runnable {

        private final BlockingQueue<Integer> queue;

        Consumer(BlockingQueue<Integer> queue) {
            this.queue = queue;
        }

        @Override
        public void run() {
            try {
                while (true) {
                    System.out.println(Thread.currentThread().getName() + " - got " + queue.take());
                    System.out.flush();
                }
            } catch (InterruptedException ie) {
                System.err.println("Shutting down consumer");
            }
        }

    }

    public static void main(String... args) throws Exception {
        BlockingQueue q = new LinkedBlockingQueue();
        Thread p = new Thread(new Demo.Producer(q));
        Thread c1 = new Thread(new Demo.Consumer(q));
        Thread c2 = new Thread(new Demo.Consumer(q));

        c2.start();
        c1.start();
        p.start();

        // Wait a bit
        Thread.sleep(1000);

        c2.interrupt();
        c2.join();

        p.interrupt();
        p.join();

        c1.interrupt();
        c1.join();
    }

}