在Java中,线程等待的正确处理方式通常使用Object类的wait()和notify()方法来实现。以下是一个简单的示例:
public class Main {
public static void main(String[] args) {
final Object lock = new Object();
Thread thread1 = new Thread(() -> {
synchronized (lock) {
try {
System.out.println("Thread 1 is waiting...");
lock.wait();
System.out.println("Thread 1 is notified.");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
Thread thread2 = new Thread(() -> {
synchronized (lock) {
System.out.println("Thread 2 is notifying...");
lock.notify();
}
});
thread1.start();
thread2.start();
}
}
在上面的示例中,Thread 1首先进入同步块,然后调用lock.wait()方法使线程进入等待状态。Thread 2在另一个线程中调用lock.notify()方法来唤醒Thread 1,使其继续执行。
需要注意的是,在调用wait()和notify()方法之前,必须先获取对象的锁(即synchronized(lock))。此外,wait()和notify()方法必须在同步块中调用,否则会抛出IllegalMonitorStateException异常。
另外,Java中还提供了wait(long timeout)方法和notifyAll()方法来更灵活地控制线程等待和唤醒的逻辑。