Java线程协作方法与实例解析
时间:2026-04-21 16:06:32 257浏览 收藏
Java线程协作的本质在于精准控制“谁该等、等什么、谁来通知”,而非单纯追求执行速度;本文系统解析了synchronized+wait/notify、Lock+Condition、CountDownLatch、CyclicBarrier、Semaphore和BlockingQueue六大核心机制,结合生产者-消费者、多任务同步启动等典型场景,深入剖析各方案的适用边界与关键陷阱——如wait必须置于while循环防虚假唤醒、notifyAll优于notify、Condition支持多条件独立等待、CountDownLatch不可重用、BlockingQueue如何将协调逻辑内化为阻塞式API;无论你是想快速落地高可靠协作逻辑,还是深入理解底层唤醒原理,这篇文章都为你划清了选型红线与实践雷区。

Java中线程协调的核心是让多个线程按预期顺序执行、共享资源时不冲突、等待特定条件满足后再继续——关键不在于“谁跑得快”,而在于“谁该等、等什么、谁来通知”。常用方式有 synchronized + wait/notify、Lock + Condition、CountDownLatch、CyclicBarrier、Semaphore 和 BlockingQueue 等,选哪种取决于协作场景。
用 wait/notify 实现简单生产者-消费者
适合一对一或简单条件等待。必须在 synchronized 块中调用,且 wait 会释放锁,notify 不释放锁。
- wait() 让当前线程进入等待队列,直到被 notify 或 notifyAll 唤醒
- notify() 随机唤醒一个等待线程;notifyAll() 唤醒所有——**推荐用 notifyAll,避免虚假唤醒导致死锁**
- wait 必须写在 while 循环里判断条件,不能用 if(防止被意外唤醒后条件仍不成立)
示例:缓冲区容量为 1 的队列
synchronized (buffer) {while (buffer.isEmpty()) {
buffer.wait(); // 消费者等待
}
int item = buffer.remove();
System.out.println("消费:" + item);
buffer.notifyAll(); // 通知生产者可以放了
}
用 ReentrantLock + Condition 精确控制等待队列
比 wait/notify 更灵活,支持多个独立条件变量,适合多角色协作(如生产者/消费者/监控线程各自等待不同条件)。
- Lock 替代 synchronized,Condition 代替 wait/notify
- 每个 Condition 对应一个等待队列,可分别 signal 而不互相干扰
- 必须显式 lock()/unlock(),建议用 try-finally 保证解锁
示例:区分“缓冲区满”和“缓冲区空”两个条件
Lock lock = new ReentrantLock();Condition notFull = lock.newCondition();
Condition notEmpty = lock.newCondition();
// 生产者:
lock.lock();
try {
while (buffer.size() == MAX_SIZE) {
notFull.await(); // 等待不满
}
buffer.add(item);
notEmpty.signal(); // 通知消费者有数据了
} finally {
lock.unlock();
}
用 CountDownLatch 做一次性“齐步走”
适用于:一个线程等待 N 个其他线程全部完成后再执行(比如主线程等所有子任务结束)。
- 构造时指定计数,countDown() 减一,await() 阻塞直到计数归零
- 计数为 0 后,所有 await 线程立即唤醒,且之后再 await 也不会阻塞——**不可重用**
- 常用于启动阶段的初始化同步、测试中模拟并发起点
示例:主线程等 3 个下载任务都完成后统一处理
CountDownLatch latch = new CountDownLatch(3);for (int i = 0; i new Thread(() -> {
download();
latch.countDown();
}).start();
}
latch.await(); // 主线程卡在这里,直到三次 countDown 完成
System.out.println("全部下载完毕");
用 BlockingQueue 实现天然线程安全的协作管道
最实用的高阶协作方式,把“协调逻辑”封装进队列本身,开发者只关注生产和消费逻辑。
- ArrayBlockingQueue(有界)、LinkedBlockingQueue(可选界)、SynchronousQueue(无缓冲,直接交接)等都线程安全
- put() 在满时阻塞,take() 在空时阻塞——无需手动 wait/notify
- 适合典型生产者-消费者模型,代码简洁、不易出错
示例:使用 LinkedBlockingQueue 构建消息通道
BlockingQueue// 生产者
new Thread(() -> {
queue.put("msg1"); // 自动阻塞等待空间
}).start();
// 消费者
new Thread(() -> {
String msg = queue.take(); // 自动阻塞等待数据
System.out.println(msg);
}).start();
基本上就这些。实际开发中,优先考虑 BlockingQueue 或 CountDownLatch 这类语义明确、不易误用的工具;只有需要精细控制唤醒逻辑时,才上 Condition;传统 wait/notify 仅建议用于学习原理或极简场景。不复杂但容易忽略细节——比如忘了循环检查条件、没配对加锁解锁、或误用 notify 导致部分线程永远等下去。
文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《Java线程协作方法与实例解析》文章吧,也可关注golang学习网公众号了解相关技术文章。
-
501 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
220 收藏
-
447 收藏
-
164 收藏
-
329 收藏
-
126 收藏
-
110 收藏
-
405 收藏
-
302 收藏
-
411 收藏
-
387 收藏
-
191 收藏
-
330 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 485次学习