在Java中如何使用条件变量_Java Condition线程通信机制说明

Condition是Lock接口提供的线程协作工具,用于替代synchronized的wait/notify,必须由Lock(如ReentrantLock)通过newCondition()创建并配合使用,支持多等待队列、超时等待及中断处理,需遵循“加锁→判断→await→处理→解锁”流程。

Java中Condition是Lock接口提供的线程协作工具,用于替代synchronized内置的wait/notify机制,实现更灵活、精准的线程等待与唤醒。

Condition必须配合Lock使用

Condition不是独立存在的,它由ReentrantLock(或其他显式锁)通过newCondition()方法创建。不能在synchronized块中使用,也不能脱离Lock单独使用。

  • 先获取锁:lock.lock()
  • 再获取Condition实例:Condition condition = lock.newCondition();
  • 释放锁前必须手动unlock(),否则会死锁

await()和signal()对应wait()和notify()

Condition.await()会让当前线程释放锁并进入等待状态;signal()唤醒一个在该Condition上等待的线程(不立即抢锁,需重新竞争);signalAll()唤醒所有。

  • await()必须在lock.lock()之后、unlock()之前调用,否则抛IllegalMonitorStateException
  • signal()不释放当前锁,唤醒后被唤醒线程需重新获取锁才能继续执行
  • 推荐在while循

    环中使用await(),避免虚假唤醒

一个Condition可支持多个等待队列

与Object的单一wait set不同,一个Lock可创建多个Condition对象,实现“按条件分组等待”。例如生产者用notFull,消费者用notEmpty,互不干扰。

  • 避免notify()误唤醒不相关的线程
  • 提升并发粒度,减少不必要的线程调度
  • 典型场景:阻塞队列(ArrayBlockingQueue内部就用了两个Condition)

注意中断与超时支持

Condition提供了更丰富的等待控制能力:

  • awaitUninterruptibly():忽略中断,一直等到被signal
  • awaitNanos(long nanosTimeout) / await(long time, TimeUnit unit):支持带超时的等待
  • awaitUntil(Date deadline):等待到指定时间点
  • 被中断时会抛InterruptedException,并自动释放锁(安全)

基本上就这些。用好Condition的关键是理解它和Lock的绑定关系,以及“先加锁→操作判断→不满足则await→满足后处理→解锁”的标准协作流程。