在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()
方法來更靈活地控制線程等待和喚醒的邏輯。