当前位置: 首页 > news >正文

问:JAVA中唤醒阻塞的线程有哪些?

在Java中,唤醒阻塞线程的方法有多种,以下是常见的线程唤醒方法。

唤醒方法

  1. 使用notify()和notifyAll()方法
synchronized (obj) {obj.notify(); // 唤醒单个等待线程// obj.notifyAll(); // 唤醒所有等待线程
}
  1. 使用interrupt()方法
Thread thread = new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {System.out.println("Thread is interrupted");}
});thread.start();
thread.interrupt(); // 中断线程,唤醒阻塞
  1. 使用LockSupport.unpark()方法
Thread thread = new Thread(() -> LockSupport.park()); // 线程阻塞thread.start();
LockSupport.unpark(thread); // 唤醒阻塞线程
  1. 使用Condition的signal()和signalAll()方法
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();new Thread(() -> {lock.lock();try {condition.await(); // 线程等待} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}
}).start();// 唤醒线程
lock.lock();
try {condition.signal(); // 或使用condition.signalAll();
} finally {lock.unlock();
}
  1. 使用Semaphore的release()方法
Semaphore semaphore = new Semaphore(0);new Thread(() -> {try {semaphore.acquire(); // 线程阻塞} catch (InterruptedException e) {e.printStackTrace();}
}).start();semaphore.release(); // 释放许可,唤醒线程
  1. 使用CountDownLatch的countDown()方法
CountDownLatch latch = new CountDownLatch(1);new Thread(() -> {try {latch.await(); // 线程阻塞} catch (InterruptedException e) {e.printStackTrace();}
}).start();latch.countDown(); // 计数减一,唤醒线程

差异

方法工作原理适用场景优点缺点使用场景示例
notify()/notifyAll()唤醒等待线程需要在synchronized块中使用,适用于简单等待/通知模式简单易用,直接唤醒容易导致死锁,不可中断等待生产者-消费者问题
interrupt()中断线程适用于任何阻塞状态(如sleep, wait, join)可中断线程,灵活性强需要处理InterruptedException异常长时间等待时中断线程
LockSupport.unpark()唤醒指定线程不依赖于锁,可灵活控制线程不需要持有锁,性能较好可能导致未预期的行为,如重复唤醒需要精确控制线程唤醒时
Condition.signal()/signalAll()唤醒等待条件线程适用于更复杂的等待/通知模式,与Lock配合使用更灵活,可精确控制唤醒条件需要持有锁,可能导致死锁复杂的生产者-消费者问题
Semaphore.release()释放许可唤醒线程适用于控制资源访问的并发数量可控制并发数,灵活性强需要管理许可数量,可能导致资源泄露资源池,限流器
CountDownLatch.countDown()计数减一唤醒线程适用于等待多个线程完成后再执行后续操作可精确控制线程等待数量不可重用,一次性使用多线程并行计算后汇总结果

结语

  • notify()/notifyAll():这两个方法用于唤醒在对象监视器上等待的线程。notify()唤醒单个线程,notifyAll()唤醒所有线程。它们必须在synchronized块中使用,因为依赖于对象锁。

  • interrupt()interrupt()方法用于中断线程,如果线程在等待、休眠或其他阻塞状态,会抛出InterruptedException异常,从而唤醒线程。这种方法灵活性强,可以中断任何阻塞状态的线程。

  • LockSupport.unpark()LockSupport提供了更底层的线程阻塞和唤醒原语。unpark()方法可以唤醒处于阻塞状态的指定线程,不依赖于对象锁,因此使用更简单灵活。

  • Condition.signal()/signalAll()Condition接口提供了更灵活的线程等待/通知模式。与Lock配合使用,可以精确控制唤醒条件,适用于更复杂的并发场景。

  • Semaphore.release()Semaphore是一种计数信号量,用于控制对资源的并发访问数量。release()方法释放一个许可,从而唤醒等待资源的线程。

  • CountDownLatch.countDown()CountDownLatch是一种同步帮助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程等待。countDown()方法递减计数器的值,当计数到达零时,唤醒所有等待的线程。

http://www.lryc.cn/news/445646.html

相关文章:

  • Github Webhook触发Jenkins自动构建
  • ESP32-WROOM-32 [创建AP站点-客户端-TCP透传]
  • 新闻文本分类识别系统Python+卷积神经网络算法+人工智能+深度学习+计算机毕设项目+TensorFlow+Django网页界面
  • Java使用Map数据结构配合函数式接口存储方法引用
  • LeetCode:2207. 字符串中最多数目的子序列(Java)
  • win10开机自启动方案总汇
  • 【自动驾驶】基于车辆几何模型的横向控制算法 | Stanley 算法详解与编程实现
  • 微服务--初识MQ
  • 车辆识别数据集,图片数量20500,模型已训练200轮
  • MES系统如何提升制造企业的运营效率和灵活性
  • Nexpose 6.6.270 发布下载,新增功能概览
  • 【数据库】sqlite
  • 详解 C++中的模板
  • 基于DAMODEL——Faster-RCNN 训练与测试指南
  • 考研数据结构——C语言实现冒泡排序
  • labview更换操作系统后打开原VI闪退
  • 什么是CAPTCHA?有什么用途?
  • 在虚幻引擎中创建毛发/头发
  • PHP API 框架:构建高效API的利器【电商API接口】
  • transformer模型写诗词
  • [大语言模型-工程实践] 手把手教你-基于Ollama搭建本地个人智能AI助理
  • 开放原子开源基金会OPENATOM
  • Docker的监控:docker stats与docker events
  • jvm专题 之 内存模型
  • 分布式计算框架
  • YOLO交通目标识别数据集(红绿灯-汽车-自行车-卡车等)
  • Vue学习记录之六(组件实战及BEM框架了解)
  • 为什么会出现电话机器人?语音电话机器人的出现起到了什么作用?
  • 【CSS Tricks】深入聊聊前端编写css的方法论
  • 多维时序 | GWO-VMD-SSA-LSTM灰狼优化变分模态分解联合麻雀优化长短期记忆网络多变量时间序列光伏功率预测(Matlab)