正文

Java wait方法如何用，多线程同步不出错

/0 浏览量
1025

在Java中，wait()方法是Object类中的一个方法，用于实现线程间的通信。当一个线程调用wait()方法时，它会释放当前对象的所有锁，并等待其他线程调用该对象的notify()或notifyAll()方法。以下是如何使用wait()方法以及如何确保多线程同步不出错的详细说明。

1. wait()方法的基本用法

wait()方法有三种形式：

  • public final void wait()：当前线程将等待，直到另一个线程调用该对象的notify()或notifyAll()方法。
  • public final void wait(long timeout)：当前线程将等待，直到另一个线程调用该对象的notify()或notifyAll()方法，或者等待超时。
  • public final void wait(long timeout, int nanos)：当前线程将等待，直到另一个线程调用该对象的notify()或notifyAll()方法，或者等待超时加上指定的纳秒数。

使用wait()方法时，需要注意以下几点：

  • wait()方法只能在同步代码块或同步方法中调用。
  • 调用wait()方法后，当前线程将释放当前对象的所有锁，并进入等待状态。
  • 当其他线程调用notify()或notifyAll()方法时，等待的线程将有机会重新获得锁，并继续执行。

2. 多线程同步的例子

以下是一个使用wait()和notify()方法的简单例子：

public class WaitNotifyExample {
    private boolean flag = false;

    public static void main(String[] args) {
        WaitNotifyExample example = new WaitNotifyExample();
        Thread t1 = new Thread(example::runT1);
        Thread t2 = new Thread(example::runT2);
        t1.start();
        t2.start();
    }

    public void runT1() {
        synchronized (this) {
            while (!flag) {
                try {
                    System.out.println("T1 is waiting");
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("T1 is notified and continues execution");
            }
        }
    }

    public void runT2() {
        synchronized (this) {
            flag = true;
            System.out.println("T2 changes the flag and notifies T1");
            notify();
        }
    }
}

在这个例子中，runT1()方法中的线程会等待flag变量变为true。当runT2()方法中的线程将flag变量设置为true并调用notify()方法时，runT1()方法中的线程将被唤醒，并继续执行。

3. 避免死锁

在使用wait()和notify()方法时，需要注意避免死锁。以下是一些避免死锁的建议：

  • 确保所有线程在调用wait()方法之前都获取了必要的锁。
  • 尽量减少持有锁的时间。
  • 使用try-catch块捕获InterruptedException，并适当处理。
  • 考虑使用Lock和Condition类，它们提供了更灵活的同步机制。

通过遵循以上建议，你可以确保在使用wait()方法时，多线程同步不出错。

-- 展开阅读全文 --