经典javaThead 生产者 消费者

在网找的一个代码，经过修改后，我认为更有代表性。因为这个代码到处都是，所以我不知道谁是原创，也就不好标明出处了。希望原作者见谅！

 1 class MainThread {
 2     public static void main(String[] args) {
 3         Queue queue = new Queue();
 4         Producer producer = new Producer(queue);
 5         Consumer consumer = new Consumer(queue);
 6         new Thread(producer).start();
 7         new Thread(consumer).start();
 8     }
 9 }
 
 /* 注意:wait notify notifyAll只能在同步方法或内步块中调用 */
 class Queue {
     int product = 0;
 
     public synchronized void setProduct() {
         if (this.product > 10) {// 如果队列已满,则调用wait等待消费者取走产品
             try {
                 wait();
             } catch (Exception e) {
                 e.printStackTrace();
             }
         }
         this.product++; /* 开始放置产品到队列中 */
         System.out.println("Product, product left:" + product);
         notify();// 生产产品后通知消费者取走产品
         try {
             Thread.sleep(20);
         } catch (InterruptedException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
     }
 
     public synchronized void getProduct() {
         if (this.product <= 0) {// 如果队列是空的,则调用wait等待生产者生产产品
             try {
                 wait();
             } catch (Exception e) {
                 e.printStackTrace();
             }
         }
         /* 开始从队列取走产品 */
         this.product--;
         System.out.println("Consume, product left:" + product);
         notify();// 取走产品后通知生产者继续生产产品
         try {
             Thread.sleep(20);
         } catch (InterruptedException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
     }
 }
 
 class Producer implements Runnable {
     Queue queue;
 
     Producer(Queue queue) {
         this.queue = queue;
     }
 
     public void run() {// 生产线程
         for (int i = 1; i <= 10; i++) {
             queue.setProduct();
         }
     }
 }
 
 class Consumer implements Runnable {
     Queue queue;
 
     Consumer(Queue queue) {
         this.queue = queue;
     }
 
     public void run() {// 消费线程
         for (int i = 1; i <= 10; i++) {
             queue.getProduct();
         }

     }

81 }