模型生产者往仓库里放产品消费者从仓库里取产品仓库一个共享的缓冲区矛盾点两边速度不同仓库空了消费者不能空手而归只能等仓库满了生产者不能再硬塞也只能等wait() 和 notify()wait()让当前线程进入等待状态挂起同时释放手里的锁。注意它不能自己醒过来必须等别人叫。notify()唤醒在同一个对象上等待的某个线程让它重新参与抢锁。核心口诀synchronized(…) 里锁的是谁wait() / notify() 前面就写谁。 三处必须是同一个对象。代码实现packagecom.dy.producer_consumer0926;//生产消费模型importjava.util.List;//wait():执行该方法的线程会进入等待状态进入该状态后不能主动恢复到运行状态//直到另一个线程利用同一个对象调用notify()方法才能唤醒该线程publicclassProducerimplementsRunnable{//仓库publicListIntegerlist;publicintMax20;//仓库的最大值publicProducer(ListIntegerlist){this.listlist;}publicvoidrun(){while(true){//同步代码块在线程安全的状态执行//监视器对象必须和调用wait方法的对象保存一致synchronized(this){//判断仓库容量if(list.size()Max){//生产一个数据list.add(1);//唤醒消费者System.out.println(生产者生产了一个产品当前库存:list.size());this.notify();}else{//当线程进入等待状态挂起try{this.wait();}catch(InterruptedExceptione){thrownewRuntimeException(e);}System.out.println(仓库已经,生产者进入等待状态...);}}}}}packagecom.dy.producer_consumer0926;importjava.util.List;publicclassConsumerimplementsRunnable{//仓库publicListIntegerlist;publicConsumer(ListIntegerlist){this.listlist;}publicvoidrun(){while(true){synchronized(this){//判断仓库有没有产品if(list.size()0){//消费一个数据list.remove(list.size()-1);System.out.println(消费者消费了一个产品当前库存为:list.size());//唤醒生产者this.notify();}else{//仓库空了当前线程进入等待状态try{this.wait();}catch(InterruptedExceptione){thrownewRuntimeException(e);}}}}}}packagecom.dy.producer_consumer0926;importjava.util.ArrayList;importjava.util.List;//测试类:创建一个共享仓库交给生产者和消费者同时使用publicclassTest{publicstaticvoidmain(String[]args){//仓库对象ListIntegerlistnewArrayList();ProducerproducernewProducer(list);ConsumerconsumernewConsumer(list);newThread(producer).start();newThread(consumer).start();}}