迹忆客 专注技术分享

本文介绍了 Java 中的 wait() 和 notification() 方法。

使用Java中的wait()和notify()方法

wait() 和 notify() 方法提供了一种允许线程等待直到满足特定条件的机制。 例如，当您想要为某些固定大小的元素后备存储编写阻塞队列实现时。

wait()和 notify() 用于Java中的保护块中，它们协调多个线程的操作。 wait() 方法用于挂起线程，notify() 方法用于唤醒线程。

wait() 方法

wait() 方法将强制当前线程等待，直到其他线程完成，或者它们调用同一对象上的 notify() 或 notifyAll() 方法。 wait() 方法可以通过以下不同方式使用：

1. 使用wait()：

   这是对 wait() 方法的简单调用，这将导致当前线程无限期地等待，直到其他线程调用notify()或notifyAll()方法。

2. 用wait(long timeout)：

   通过调用wait()方法，我们可以指定一个超时时间，超时后线程将被自动唤醒，其中超时时间是一个很长的时间值。

   还可以使用notify()和notifyAll()方法在超时之前唤醒线程。 将值 0 放入超时参数中的工作方式与 wait() 调用类似。

3. 使用 wait(long timeout, int nanos)：

   此调用的工作方式也与 wait(long timeout) 类似。 唯一的区别是我们可以提供更高的精度。

   超时时间以纳秒为单位计算为 1_000_000*timeout + 纳秒。

notify() 和 notifyAll() 方法

notify() 功能用于唤醒等待访问对象监视器的线程。 notification() 功能可以通过两种方式使用：

1. 使用notify()：

   对于所有等待的线程，notify()方法只会通知一个特定的线程被唤醒。 选择要唤醒的线程不是确定性的，这取决于实现。

   由于notify()只能唤醒一个线程，当我们想要唤醒多个线程时，它可能就没用了。

2. 使用notifyAll()：

   notifyAll()将唤醒对象监视器上的所有线程。 当线程被唤醒时，它们将像其他线程一样以通常的方式完成。

   让我们尝试一个使用 wait() 方法阻塞线程并使用 notification() 方法唤醒线程的示例：

package jiyik;

import java.util.LinkedList;
import java.util.Queue;

public class Example<T> {

    private Queue<T> Demo_Queue = new LinkedList<T>();
    private int Q_Capacity;

    public Example(int Q_Capacity) {
        this.Q_Capacity = Q_Capacity;
    }

    public synchronized void put(T Demo_Element) throws InterruptedException {
        while(Demo_Queue.size() == Q_Capacity) {
            wait();
        }

        Demo_Queue.add(Demo_Element);
        // Wake up the thread. notifyAll() can also be used for multiple threads
        notify();
    }

    public synchronized T take() throws InterruptedException {
        while(Demo_Queue.isEmpty()) {
            // Ask the thread to wait
            wait();
        }

        T item = Demo_Queue.remove();
        // Wake up the thread. notifyAll() can also be used for multiple threads
        notify();
        return item;
    }
}

上面的代码演示了一个简单的队列阻塞操作，我们需要确保任何 wait() 和 notification() 调用都位于代码的同步区域中。