Java 多线程（五）—— 阻塞队列、wait、notify

wait

wait 和 notify 都是 Object 类提供的方法，也就是说 Java 恣意对象都可以使用 这两个方法。

起首 wait 会抛出 InterruptedException 这个非常，阐明这个方法可以被 interrupt 给唤醒。
然后我们是不能直接使用 wait 方法的，否则还会抛出下面的非常：

IllegalMonitorStateException 黑白法的锁状态，monitor 是监视器 也就是我们 的 synchronized ，背面 current thread is not owner ，是说当前的线程不是这把锁的拥有者，阐明我们要想使用 wait 方法 就必要先得到这把锁

1.     public static void main(String[] args) throws InterruptedException {
2.         Object locker = new Object();
3.         synchronized(locker) {
4.             locker.wait();
5.         }
6.     }

复制代码

  wait 的作用是让当前的线程先释放这把锁，然后进入 waiting（死等） 状态，当然 wait 也和 sleep 一样也可以设置时间，当该线程在规定时间内没有被唤醒，就会主动唤醒，重新争夺锁。这时候有时间限制的 wait 的线程状态就是 time_waiting 状态。
  我们来看一下wait 的流程图：

   wait 和 sleep 的区别：
起首在 synchronized 下， wait 是会释放掉锁的，但是sleep 不会，sleep 会抱着锁一起睡
wait 的使用必须搭配锁， sleep 不必要
  

---

当我们使用 wait 的时候一般是搭配条件判定的，这里建议 将条件判定换成 while 循环语句，这也是Java 标准库里写明的：

   翻译：等待的最佳方法是在等待调用四周的 while 循环中检查正在等待的条件，如下面的例子所示。这种方法可以避免由随机唤醒引起的问题。
  这个方案其实是操作系统原生的 api 就建议过 wait 搭配 while，Java 只是继续前人的意志，当然具体你要使用 if 还是使用 while 还是要看具体问题具体分析的。
   因为 wait 可能会被 interrupt() 给唤醒，如果使用 if 作为判定，此时就可能会存在 wait 被提前唤醒的 情况。
  notify

notify 是唤醒线程，在操作系统原生的api 中 调用 notify 的线程是可以不用得到对应对象的锁的，但是在Java中规定了 notify 的使用和 wait 是一样都必要先得到这把锁对象。
   wait 和 notify 针对的是同一个对象，notify 才能生效， wait 的线程才能被唤醒

1. public class Main {
2.     public static void main(String[] args) {
3.         Object locker = new Object();
4.         Thread t1 = new Thread(() -> {
5.             synchronized(locker) {
6.                 try {
7.                     System.out.println("t1 wait 之前");
8.                     locker.wait();
9.                     System.out.println("t1 wait 之后");
10.                 } catch (InterruptedException e) {
11.                     throw new RuntimeException(e);
12.                 }
13.             }
14.         });
16.         Thread t2 = new Thread(() -> {
17.             synchronized (locker) {
18.                 System.out.println("t2 开始唤醒 t1");
19.                 locker.notify();
20.             }
21.         });
22.         t1.start();
23.         t2.start();
24.     }

复制代码

   一个 notify 只能唤醒一个 wait ，如果有多个 wait 的话，一个 notify 会随机唤醒其中一个 wait 线程
如果你想唤醒全部的 wait 线程，可以使用 notifyAll()
    如果notify 在 wait 之前就已经运行了，那 背面的 wait 是不会吸收到 前面的 notify 信号的，所以我们要确保 notify 在 wait 之后执行，避免程序卡住。
  

---

   wait 和 notify 的使用不但仅是为了线程等待和线程唤醒这些根本的操作，其实还有一个作用，就是让线程释放掉锁，也就是当线程此时不满意条件无法进行工作的时候，应该将锁资源释放掉，给其他线程用用，这也避免了线程饥饿问题（线程迟迟没能得到 CPU 资源而运行），进而进步资源的利用率
  阻塞队列

阻塞队列是另一种设计模式，是为了实现生产者和消费者模型的。

生产者负责生产，生产出来的产品会被消费者进行斲丧，而我们的阻塞队列其实就是毗连生产者和消费者的管道，阻塞队列是由容量的，当生产者生产速度过快，消费者的消费速度跟不上生产的速度，阻塞队列在某一个时刻就会发生阻塞，即当丢列已满的情况下，生产者不能继续生产往队列里面填充产品。
同理，当消费者的消费速度过快，生产者跟不上其消费速度，阻塞队列就会在某一个时刻为空，此时消费者就不能继续从队列里获取产品了，即当丢列为空的时候，消费者会处于阻塞状态。
   阻塞队列的特性
当队列为空，实验进行出队列的操作，这时候进行出队列的操作的线程会发生阻塞，直到其他线程添加其他元素未知
当队列已满，实验进行入队列的操作，这时候进行入队列操作的线程会发生阻塞，直到其他线程从队列取走元素为止
  

---

在实际开发过程中，我们如果要使用阻塞队列，很有可能会将一个阻塞队列放在一个服务器（机器 / 集群）上进行部署。
原先不使用阻塞队列的时候，A 服务器和 B 服务器直接进行交互，很有可能发生一件事变：当 A 服务器发出过量的哀求的时候，B 服务器就可能无法处理这么多哀求而发生崩溃，这个例子各人请参考学校的教务系统之选课环节。

当我们使用阻塞队列，而且把它部署到一个集群上时：

A 服务器和 B服务器就会与队列进行交互，从而实现 削峰填谷，纵然A 服务器 有一大波哀求涌来，这时候这一波数据并不会直接被 B 服务器吸收，而是被 队列给拦下来了，B 服务器依旧可以按照自己的节奏从 队列里获取哀求然后进行相应，这样 B 服务器就没这么容易崩溃。
不但云云，还能实现 代码的 解耦合，这样的部署，就会使 A 和 B 的代码耦合性变低。
当然也有一个不好的地方，就是你多使用了一个机器来部署阻塞队列，这时候会增加机器的复杂性，生产情况会变得复杂，管理难度上升。而且引入队列，A 和 B服务器不是直接交互，效率也会受到影响
   阻塞队列的长处：解耦合，削峰填谷
缺点：加机器的复杂性，生产情况会变得复杂，管理难度上升
效率受到影响
  使用

在 Java 中给我们提供了一个阻塞队列的 类 BlockingQueue

我们可以从上面直到这是一个接口，继续 Queue，阐明我们可以使用 queue 的方法，但是留意 这是一个阻塞队列，Java 给我们提供了带有阻塞功能的 方法 put() 和 take()

---

由于 BlockingQueue 本身是一个接口，所以无法直接实例化，Java 给我们提供了下面的实例化方式，我们可以创建基于数组实现的阻塞队列、基于链表实现的阻塞队列、也可以创建带有优先级的阻塞队列、还可以创建双端队列

---

当我们使用 put 和 take 方法的时候记得抛出 InterruptedException 非常

1. import java.util.concurrent.ArrayBlockingQueue;
2. import java.util.concurrent.BlockingQueue;
4. public class Demo2 {
5.     public static void main(String[] args) throws InterruptedException {
6.         BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
7.         queue.put(10);
8.         queue.take();
9.     }
10. }

复制代码

模仿实现

现在我们来模仿实现一个基于数组实现的阻塞循环队列。

1. class MyBlockingQueue {
2.     private int[] elem;
3.     private int size;
4.     private int head;
5.     private int tail;
7.     Object locker = new Object();
9.     public MyBlockingQueue(int capacity) {
10.         elem = new int[capacity];
11.     }
13.     public void put(int x) throws InterruptedException {
14.         synchronized (locker) {
15.             while (size == elem.length) {
16.                 locker.wait();
17.             }
18.             elem[tail] = x;
19.             tail++;
20.             if (tail == elem.length) {
21.                 tail = 0;
22.             }
23.             size++;
24.             locker.notify();
25.         }
26.     }
28.     public int take() throws InterruptedException {
29.         synchronized (locker) {
30.             while (size == 0) {
31.                 locker.wait();
32.             }
33.             int x = elem[head];
34.             head++;
35.             if (head == elem.length) {
36.                 head = 0;
37.             }
38.             size--;
39.             locker.notify();
40.             return x;
41.         }
42.     }
43. }

复制代码

这里着重介绍 wait 和 notify 的作用，当我们进行 put 操作的时候，如果发现队列已满，我们必要进入线程等待状态，比及 take 拿走元素之后就进行 notify 操作唤醒 put ；同理，当进行 take 操作的时候，如果发现队列为空，要进入等待状态，比及 put 放入元素之后进行 notify 操作唤醒 take

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。