多线程 生产者消费者模式 线程之间的通讯问题

class Producer implements Runnable {  

 *   private final BlockingQueue queue;  

 *   Producer(BlockingQueue q) { queue = q; }  

 *   public void run() {  

 *     try {  

 *       while(true) { queue.put(produce()); }  

 *     } catch (InterruptedException ex) { ... handle ...}  

 *   }  

 *   Object produce() { ... }  

 * }  

 *  

 * class Consumer implements Runnable {  

 *   private final BlockingQueue queue;  

 *   Consumer(BlockingQueue q) { queue = q; }  

 *   public void run() {  

 *     try {  

 *       while(true) { consume(queue.take()); }  

 *     } catch (InterruptedException ex) { ... handle ...}  

 *   }  

 *   void consume(Object x) { ... }  

 * }  

 *  

 * class Setup {  

 *   void main() {  

 *     BlockingQueue q = new SomeQueueImplementation();  

 *     Producer p = new Producer(q);  

 *     Consumer c1 = new Consumer(q);  

 *     Consumer c2 = new Consumer(q);  

 *     new Thread(p).start();  

 *     new Thread(c1).start();  

 *     new Thread(c2).start();  

 *   }  

 * }