有一个仓库，有最大容量
货满了通知消费者取货，货没了，消费者取不了货
管理员可以加货，消费者减货
分析：
仓库类，提供一个取货和加货的方法，这两个方法就是操作同一个资源，需要实现同步
加货，先判断是否超过了仓库的最大容量，超过就通知取货，否则才加货
取货，先判断还有没有货，没有货就通知加货，有货才能取货
两个加货线程加两个取货线程，实现资源共享
释放锁实现生产者和消费者
使用Object的wait方法挂起，进入等待池
使用Object的notifyAll()，让出锁
这里用while是因为醒了会在判断一次，出不去，如果是if就直接往下面走了，就会造成超出最大范围或者出现负数
class WareHome {
private int max_ware;
private int count;
public WareHome(int max_ware){
this.max_ware=max_ware;
}
public synchronized void add(){
while(count==max_ware){
System.out.println("货满了，无法加入");
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("加了一件货，剩余货物："+(++count)+Thread.currentThread().getName());
this.notifyAll();
}
public synchronized void remove(){
while(count==0){
System.out.println("没有货了..");
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("去了一件货，剩余货物："+(--count)+Thread.currentThread().getName());
this.notifyAll();
}
}
class User extends Thread{
private WareHome wareHome;
public User(WareHome wareHome){
this.wareHome=wareHome;
}
public void run(){
while(true){
try {
Thread.sleep(1000*5);
} catch (InterruptedException e) {
e.printStackTrace();
}
wareHome.remove();
}
}
}
class Admin extends Thread{
private WareHome wareHome;
public Admin(WareHome wareHome){
this.wareHome=wareHome;
}
public void run(){
while(true){
try {
Thread.sleep(1000*1);
} catch (InterruptedException e) {
e.printStackTrace();
}
wareHome.add();
}
}
}
public static void main(String[] args) {
WareHome wareHome = new WareHome(5);
Admin admin01= new Admin(wareHome);
Admin admin02= new Admin(wareHome);
User user01=new User(wareHome);
User user02=new User(wareHome);
admin01.start();
admin02.start();
user01.start();
user02.start();
}
