0

0

在Java里Condition接口如何协调线程_Java线程同步高级控制解析

P粉602998670

P粉602998670

发布时间:2026-02-05 12:59:02

|

901人浏览过

|

来源于php中文网

原创

Condition是Lock配套的条件等待接口,支持多条件分组唤醒;而synchronized仅有一个隐式等待队列。它需通过lock.newCondition()获取,await()/signal()必须在lock()/unlock()内调用,且须用while循环检查条件以防虚假唤醒。

在java里condition接口如何协调线程_java线程同步高级控制解析

Condition 是什么,和 synchronized 有什么区别

Conditionjava.util.concurrent.locks 包下的接口,必须配合 Lock(如 ReentrantLock)使用,不能替代 synchronized。它提供比 wait()/notify() 更精细的线程等待/唤醒控制——比如一个锁可以绑定多个 Condition 实例,实现「按条件分组唤醒」,而 synchronized 下每个对象只有一个隐式等待队列。

常见误用是直接 new Condition(),但它是接口,必须通过 lock.newCondition() 获取;也有人试图在 synchronized 块里调用 condition.await(),这会抛 IllegalMonitorStateException,因为 await() 要求当前线程持有对应 Lock,而非内置锁。

await() / signal() 必须成对出现在 lock() / unlock() 之间

所有 await()signal()signalAll() 调用都必须发生在 lock.lock() 之后、lock.unlock() 之前。否则运行时会报 IllegalMonitorStateException

典型安全写法:

立即学习Java免费学习笔记(深入)”;

lock.lock();
try {
    while (!ready) {
        condition.await(); // 等待条件成立
    }
    // 执行业务逻辑
} finally {
    lock.unlock();
}

注意:必须用 while 判断条件,不能用 if——因为虚假唤醒(spurious wakeup)可能发生,await() 返回不保证条件真成立。

  • await() 会自动释放锁,并挂起当前线程
  • signal() 唤醒后,线程需重新竞争锁;获得锁后才从 await() 返回
  • signal() 不释放锁,也不影响当前锁持有状态

多个 Condition 实现精准唤醒(比如生产者-消费者分离)

一个 ReentrantLock 可创建多个 Condition,例如生产者等「有空位」,消费者等「有数据」,两者互不干扰:

PaperFake
PaperFake

AI写论文

下载
private final Lock lock = new ReentrantLock();
private final Condition notFull  = lock.newCondition();
private final Condition notEmpty = lock.newCondition();

当生产者发现队列满时调用 notFull.await(),消费者消费后调用 notFull.signal();消费者发现空时调用 notEmpty.await(),生产者插入后调用 notEmpty.signal()。这样避免了 notifyAll() 带来的无差别唤醒开销。

容易忽略的点:signal() 并不保证立即唤醒——如果此时没有线程在该 Condition 上等待,这次调用就静默丢失;所以业务逻辑中不能依赖「发 signal 就一定有响应」,仍要靠循环检查条件变量。

中断敏感性:await() 可被 interrupt,signal() 不可中断

await() 有两种常用变体:await()awaitUninterruptibly()。前者响应线程中断,抛 InterruptedException 并清除中断状态;后者忽略中断,直到被 signal 或虚假唤醒。

如果你的线程需要支持优雅中断(比如任务取消),应该捕获 InterruptedException 并在 finally 块中恢复中断状态或退出循环:

try {
    condition.await();
} catch (InterruptedException e) {
    Thread.currentThread().interrupt(); // 恢复中断标记
    return; // 或抛出 RuntimeException 包装
}

signal()signalAll() 本身不会抛异常,也不响应中断;它们只是向等待队列投递唤醒信号,真正处理中断的是被唤醒后重新竞争锁并返回的线程。

真正难调试的点往往不在语法,而在「谁在等、谁在唤、条件变量是否及时更新、有没有漏掉 signal」——这些错位不会立刻崩溃,而是导致死锁或线程永远挂起。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

794

2023.08.22

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

98

2023.09.25

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1259

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

275

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2196

2025.12.29

java接口相关教程
java接口相关教程

本专题整合了java接口相关内容,阅读专题下面的文章了解更多详细内容。

33

2026.01.19

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

609

2023.08.10

微信网页版文件传输助手教程合集
微信网页版文件传输助手教程合集

本专题整合了微信网页版文件传输助手教程、入口等等内容,阅读专题下面的文章了解更多详细内容。

15

2026.02.04

微信文件过期恢复教程
微信文件过期恢复教程

本专题整合了微信文件过期恢复方法、技巧教程,阅读专题下面的文章了解更多详细内容。

10

2026.02.04

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 3.2万人学习

C# 教程
C# 教程

共94课时 | 8.6万人学习

Java 教程
Java 教程

共578课时 | 57.7万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号