本文共 3581 字，大约阅读时间需要 11 分钟。

本文通过两种方法解决生产者--消费者问题，思想都是通过锁的竞争进行资源的消耗或者生产，如果有疑问或者写的不好的地方可以留言沟通（代码中都作了详细的注释）

目录

方法一：synchronized, wait, notify 

1.1 资源

1.2 消费者

1.3 生产者

1.4 测试代码

方法二：lock, condition, await, signal

2.1 资源

2.2 消费者

2.3 生产者

2.4 测试代码

三 结果

方法一：synchronized, wait, notify 

1.1 资源

 

public class Resource {     //当前资源的数量     int num = 0;     //当前资源的上限     int size = 10;       //消费资源     public synchronized void remove() {         //如果num为0，没有资源了，需要等待         while (num == 0) {//这里jdk源码里推荐用while，因为有可能出现虚假唤醒，所以要再次确认             try {                 System.out.println("消费者进入等待");                 this.wait();//线程等待，并释放锁             } catch (InterruptedException e) {                 e.printStackTrace();             }         }         //如果线程可以执行到这里，说明资源里有资源可以消费         num--;         System.out.println("消费者线程为:" + Thread.currentThread().getName() + "--资源数量:" + num);         this.notify();//唤醒其他正在等待的线程     }       //生产资源     public synchronized void put() {         //如果资源满了，就进入阻塞状态         while (num == size) {//这里jdk源码里推荐用while，因为有可能出现虚假唤醒，所以要再次确认             try {                 System.out.println("生产者进入等待");                 this.wait();//线程进入阻塞状态，并释放锁               } catch (InterruptedException e) {                 e.printStackTrace();             }         }           num++;         System.out.println("生产者线程为:" + Thread.currentThread().getName() + "--资源数量:" + num);         this.notify();//唤醒其他正在等待的线程     } } 1.2 消费者

public class Consumer implements Runnable {

      private Resource resource;       public Consumer(Resource resource) {         this.resource = resource;     }       @Override     public void run() {         while (true){             resource.remove();         }       } } 1.3 生产者

 

public class Producer implements Runnable {       private Resource resource;       public Producer(Resource resource){         this.resource=resource;     }       @Override     public void run() {         while (true){             resource.put();         }     } } 1.4 测试代码

public class TestConsumerAndProducer {

      public static void main(String[] args) {         Resource resource = new Resource();         //生产线程         Producer p1 = new Producer(resource);         //消费线程         Consumer c1 = new Consumer(resource);           new Thread(p1).start();           new Thread(c1).start();     } } 方法二：lock, condition, await, signal

2.1 资源

 

public class Resource {     //当前资源的数量     private int num = 0;     //当前资源的上限     private int size = 10;     private Lock lock = new ReentrantLock();//创建锁对象     private Condition condition = lock.newCondition();//创建锁的条件，情况       //消费资源     public void remove() {         try {             lock.lock();//开启锁             //如果num为0，没有资源了，需要等待             while (num == 0) {//这里jdk源码里推荐用while，因为有可能出现虚假唤醒，所以要再次确认                 try {                     System.out.println("消费者进入等待");                     condition.await();//线程等待，并释放锁                 } catch (InterruptedException e) {                     e.printStackTrace();                 }             }             //如果线程可以执行到这里，说明资源里有资源可以消费             num--;             System.out.println("消费者线程为:" + Thread.currentThread().getName() + "--资源数量:" + num);             condition.signal();//唤醒其他等待的线程         } finally {             lock.unlock();//释放锁         }       }       //生产资源     public  void put() {         try {             lock.lock();//开启锁             //如果资源满了，就进入阻塞状态             while (num == size) {//这里jdk源码里推荐用while，因为有可能出现虚假唤醒，所以要再次确认                 try {                     System.out.println("生产者进入等待");                     condition.await();//线程等待，并释放锁                 } catch (InterruptedException e) {                     e.printStackTrace();                 }             }             num++;//如果线程执行到这里，说明资源未满，可以开始生产             System.out.println("生产者线程为:" + Thread.currentThread().getName() + "--资源数量:" + num);             condition.signal();//唤醒其他等待的线程         }finally {             lock.unlock();//释放锁         }       } } 2.2 消费者

public class Consumer implements Runnable {

      private Resource resource;       public Consumer(Resource resource) {         this.resource = resource;     }       @Override     public void run() {         while (true){             resource.remove();         }       } } 2.3 生产者

public class Producer implements Runnable {

      private Resource resource;       public Producer(Resource resource){         this.resource=resource;     }       @Override     public void run() {         while (true){             resource.put();         }     } } 2.4 测试代码

public class TestConsumerAndProducer {

      public static void main(String[] args) {         Resource resource = new Resource();         //生产线程         Producer p1 = new Producer(resource);         //消费线程         Consumer c1 = new Consumer(resource);           new Thread(p1).start();           new Thread(c1).start();     } } 三 结果