Java wait和notifyAll实现简单的阻塞队列

Java wait和notifyAll实现简单的阻塞队列 在 Java 中，wait 和 notifyAll 是两个非常重要的方法，它们都是在 Object 类中声明的，用于实现线程之间的通信和同步。wait 方法会使调用线程进入等待状态，并释放所持有的对象锁，而 notifyAll 方法则会去唤醒当前对象的所有等待线程。 在本文中，我们将通过一个简单的阻塞队列的示例代码，来演示如何使用 wait 和 notifyAll 实现线程之间的同步和通信。 让我们来看一下阻塞队列的实现。阻塞队列是一个特殊的队列，当队列为空时，消费者线程会被阻塞，而生产者线程会继续生产数据。当队列满时，生产者线程会被阻塞，而消费者线程会继续消费数据。 在我们的示例代码中，我们使用了两个锁对象，addLock 和 deleteLock，分别用于生产者线程和消费者线程的同步。我们还使用了 AtomicInteger 来记录队列中的数据数量，因为普通的 int 变量在多线程环境下可能会出现非原子性问题。 在 add 方法中，我们首先获取 addLock 锁，然后判断队列是否已经满了，如果满了，则调用 wait 方法使当前线程进入等待状态，直到消费者线程消费了数据。如果队列没有满，则存放数据，并递增数据数量。如果队列中有数据，则调用 notifyAll 方法唤醒消费者线程。 在 poll 方法中，我们首先获取 deleteLock 锁，然后判断队列是否为空，如果为空，则调用 wait 方法使当前线程进入等待状态，直到生产者线程生产了数据。如果队列不为空，则获取数据，并递减数据数量。如果队列没有满，则调用 notifyAll 方法唤醒生产者线程。 通过这个示例代码，我们可以看到，wait 和 notifyAll 方法是如何用于实现线程之间的同步和通信的。它们可以帮助我们实现高效、可靠的多线程编程。 需要注意的是，在使用 wait 和 notifyAll 方法时，必须先获取到对象锁，否则会抛出 IllegalMonitorStateException 异常。此外，wait 方法也可以使调用线程进入等待状态，而不需要释放对象锁。 此外，我们还可以使用 join 方法来实现线程之间的同步。join 方法会使当前线程进入等待状态，直到另一个线程执行完成。如果没有设置等待时间，则当前线程将一直等待直到另一个线程执行完成。 wait 和 notifyAll 方法是 Java 多线程编程中非常重要的概念，它们可以帮助我们实现高效、可靠的多线程编程。