在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()
方法来更灵活地控制线程等待和唤醒的逻辑。