本文共 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, signal2.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(); } } 三 结果