多线程（生产者，消费者）的简单实现

package com.lzg;
public class ThreadDemo02 {
 public static void main(String[] args) {
  Resource resource = new Resource();
  Thread p1 = new Thread(new Producer("生产者1 ", 50, resource));
  Thread p2 = new Thread(new Producer("生产者2 ", 30, resource));
  Thread c1 = new Thread(new Custormer("消费者1 ", 50, resource));
  Thread c2 = new Thread(new Custormer("消费者2 ", 30, resource));
  p1.start();
  p2.start();
  c1.start();
  c2.start();
 }
}
class Resource {
 public static final int MAX_SIZE = 100;
 private int current_size = 0;
 public int getCurrent_size() {
  return current_size;
 }
 public void setCurrent_size(int current_size) {
  this.current_size = current_size;
 }
 public synchronized void produrce(int num, String name) {
  System.out.println("当前仓库剩余容量: " + (Resource.MAX_SIZE - current_size) + "----------" + name + "准备生产: " + num);
  while (current_size + num > Resource.MAX_SIZE) // 超过最大容量
  {
   try {
    System.out.println("仓库存不下，请等待");
    wait();
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
  current_size += num;
  System.out.println(name + "生产了 : " + num + "个产品-------------------" + "当前仓库剩余容量为"
    + (Resource.MAX_SIZE - current_size));
  notify();
 }
 public synchronized void consume(int num, String name) {
  System.out.println("当前仓库剩余产品: " + current_size + "********" + name + " 准备消费: " + num);
  while (current_size < num) {
   try {
    System.out.println("仓库没货，请等待");
    wait();
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
  current_size -= num;
  System.out.println(name + "已经消费: " + num + "************ 当前仓库剩余产品: " + current_size);
  notify();
 }
}
class Producer implements Runnable {
 private Resource r;
 private String name;
 private int num;
 public Producer(String name, int num, Resource r) {
  this.name = name;
  this.num = num;
  this.r = r;
 }
 @Override
 public void run() {
  // TODO Auto-generated method stub
  int i = 0;
  while (i++ < 10) {
   r.produrce(num, name);
  }
 }
}
class Custormer implements Runnable {
 private Resource r;
 private String name;
 private int num;
 public Custormer(String name, int num, Resource r) {
  this.name = name;
  this.num = num;
  this.r = r;
 }
 @Override
 public void run() {
  // TODO Auto-generated method stub
  int i = 0;
  while (i++ < 10) {
   r.consume(num, name);
  }
 }
}