java wait()方法如何进行线程协调

在Java中，wait()方法是Object类的一个方法，用于让当前线程等待，直到其他线程调用同一个对象的notify()或notifyAll()方法。wait()方法通常与synchronized关键字和Lock接口一起使用，以实现线程之间的协调。

以下是使用wait()方法进行线程协调的步骤：

1. 将对象声明为synchronized：为了让线程能够调用wait()和notify()方法，需要将对象声明为synchronized。这样，一次只有一个线程可以访问该对象的同步代码块。

public synchronized void waitForSignal() throws InterruptedException {
    wait();
}

2. 使用wait()方法：在同步代码块中，调用wait()方法让当前线程等待。这将导致线程进入等待状态，并释放对象的锁。

public synchronized void waitForSignal() throws InterruptedException {
    wait();
}

3. 使用notify()或notifyAll()方法：当另一个线程需要通知等待的线程时，可以调用对象的notify()或notifyAll()方法。notify()方法只唤醒一个等待的线程，而notifyAll()方法会唤醒所有等待的线程。

public synchronized void sendSignal() {
    notify(); // 或者使用 notifyAll() 唤醒所有等待的线程
}

4. 编写线程类：创建一个实现Runnable接口的线程类，并在其run()方法中调用同步对象的waitForSignal()和sendSignal()方法。

public class MyThread implements Runnable {
    private final Object signalObject;

    public MyThread(Object signalObject) {
        this.signalObject = signalObject;
    }

    @Override
    public void run() {
        try {
            System.out.println(Thread.currentThread().getName() + " is waiting for signal.");
            signalObject.waitForSignal();
            System.out.println(Thread.currentThread().getName() + " has received the signal.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

5. 创建并启动线程：在主类中，创建MyThread对象并启动线程。

public class Main {
    public static void main(String[] args) {
        Object signalObject = new Object();
        MyThread thread1 = new MyThread(signalObject);
        MyThread thread2 = new MyThread(signalObject);

        Thread thread1Instance = new Thread(thread1);
        Thread thread2Instance = new Thread(thread2);

        thread1Instance.start();
        thread2Instance.start();

        try {
            Thread.sleep(1000); // 等待一段时间，以便线程可以执行
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("Main thread is sending signal.");
        signalObject.sendSignal();
    }
}

这个示例中，两个线程thread1和thread2等待一个信号对象signalObject的wait()方法。主线程在启动子线程后休眠1秒钟，然后调用signalObject的sendSignal()方法唤醒一个等待的线程。被唤醒的线程将继续执行并输出接收到信号的消息。