线程的一次学习笔记

https://mp.weixin.qq.com/s/oqKHrl_xZjU-oE9YsR6koA

本次笔记,记录的是“如何理解上文中的一些内容”?

1、原文:

“当发现队列满了后,就会调用变量queue的wait()方法,该生产者线程就会被进入等待状态,并且释放Queue对象的监视器锁,让其他生产者线程和消费者线程去竞争这个监视器锁,打破了死锁产生的四个条件中的请求并持有条件,避免发生死锁,同样的,当发现队列空了后,也会调用变量queue的wait()方法,该消费者线程会进入等待状态,并且释放Queue对象的监视器锁,让其他消费者线程和生产者线程去竞争这个监视器锁,打破了死锁的四个条件中的请求并持有条件,避免发生死锁”

理解:

调用wait会释放锁,由其他线程(生产线程、消费线程)进行抢占,待当前线程再次抢占到锁的时候,才会继续执行后续代码。

public void produce() {
   LogUtils.i(TAG, "执行生产0");
   synchronized (queue) {
      LogUtils.i(TAG, "执行生产------------");
      while (queue.size() == MAX_SIZE) {
         try {
            LogUtils.i(TAG, "生产者(线程名:" + Thread.currentThread().getName() + ":库存已满");
            //队列满后,调用wait,生产线程进入等待状态,释放Queue对象的监视器锁。
            queue.wait();
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
      //如果队列没满,创建新的Object对象放在队尾
      queue.offer(new Object());
      LogUtils.i(TAG,"生产者(线程名:" + Thread.currentThread().getName() + "生产一个产品");
      //通知其他生产者线程和消费者线程
      queue.notifyAll();
   }
}

public void consume() {
   LogUtils.i(TAG, "执行销售0");
   synchronized (queue) {
      LogUtils.i(TAG, "执行销售------------");
      while (queue.size() == 0) {
         try {
            LogUtils.i(TAG, "消费者(线程名:" + Thread.currentThread().getName() + ":库存已空");
            queue.wait();
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
      //如果队列存在元素,将队首元素出列
      queue.poll();
      LogUtils.i(TAG, "消费者(线程名:" + Thread.currentThread().getName() + ":消费一个产品");
      //通知其他消费者线程和生产者线程
      queue.notifyAll();

   }
}

线程的一次学习笔记