北京定制网站建设十大导航软件
2026/6/28 11:03:29 网站建设 项目流程
北京定制网站建设,十大导航软件,网上服务,开发公司年终总结从synchronized到LockCondition前言1. 先说传统方式#xff1a;synchronized wait/notify2. 重头戏#xff1a;Lock Condition#xff08;强烈推荐#xff01;#xff09;为什么推荐它#xff1f;核心组件#xff1a;关键规则#xff1a;为什么能精确唤醒#xff1f…从synchronized到LockCondition前言1. 先说传统方式synchronized wait/notify2. 重头戏Lock Condition强烈推荐为什么推荐它核心组件关键规则为什么能精确唤醒在实际项目中的应用阻塞队列3. 两种方式对比总结结论新项目直接用Lock Condition老方式只用来理解历史。前言今天来聊聊Java多线程里一个超级经典的话题——等待唤醒机制。在多线程编程里我们经常遇到“线程协作”的场景比如一个线程生产数据另一个线程消费数据或者两个线程需要严格交替执行像乒乓球一样你一下我一下。这时候就需要“等待唤醒”条件不满足时线程自己睡一觉等条件好了再被叫醒继续干活。Java提供了两种实现方式老派synchronized wait()/notify()新派推荐Lock Condition今天重点讲Lock Condition因为它更灵活、更高效是现代并发编程的主流Java并发包里的阻塞队列都是用这个实现的。我们会用一个简单例子——两个线程交替打印0~9——来一步步讲解。1. 先说传统方式synchronized wait/notify这是JDK 1.0就有的方式简单但有局限。核心规则必须在synchronized同步块里调用wait()/notify()。wait()当前线程释放锁进入等待状态睡大觉。notify()随机唤醒一个等待线程。notifyAll()唤醒所有等待线程生产者消费者场景通常用这个避免“假死”。必须用while检查条件重要防止伪唤醒。简单例子交替打印publicclassSyncWaitNotifyDemo{privatestaticfinal Object locknewObject();// 共享锁对象privatestaticint num0;privatestaticboolean isATurntrue;// true: A的回合publicstaticvoidmain(String[]args){newThread(()-{while(num10){synchronized(lock){while(!isATurn){// 用while防伪唤醒try{lock.wait();// 不是我的回合释放锁等待}catch(InterruptedException e){e.printStackTrace();}}System.out.println(A打印: num);isATurnfalse;lock.notifyAll();// 唤醒所有安全}}},A).start();newThread(()-{while(num10){synchronized(lock){while(isATurn){try{lock.wait();}catch(InterruptedException e){e.printStackTrace();}}System.out.println(B打印: num);isATurntrue;lock.notifyAll();}}},B).start();}}它能工作但缺点明显只有一个等待队列所有线程混在一起。notifyAll()会把所有线程都唤醒即使不需要醒来后又发现条件不满足再wait——浪费性能叫“惊群效应”。不支持超时、精确唤醒等高级功能。2. 重头戏Lock Condition强烈推荐从JDK 1.5开始JUC包java.util.concurrent引入了ReentrantLock和Condition彻底升级了等待唤醒机制。为什么推荐它精确唤醒一个Lock可以创建多个Condition每个Condition有独立的等待队列。你可以“只唤醒消费者”或“只唤醒生产者”不浪费。功能更强支持超时等待awaitNanos、不可中断等待等。性能更好避免惊群高并发下更快。灵活公平锁可选避免线程饥饿。核心组件ReentrantLock lock new ReentrantLock();可重入锁手动加锁解锁。Condition cond lock.newCondition();可以创建多个每个是一个独立等待队列。cond.await()释放锁当前线程进入该Condition的等待队列睡大觉。cond.signal()只唤醒该队列的一个线程。cond.signalAll()唤醒该队列的所有线程。关键规则必须先lock.lock()获取锁再操作Condition。unlock()一定要放finally里防止死锁。永远用while检查条件防伪唤醒。完整例子交替打印0~9带详细注释Javaimport java.util.concurrent.locks.Condition;importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassLockConditionDemo{privatestaticfinal Lock locknewReentrantLock();// 一把可重入锁所有线程共享privatestaticfinal Condition condAlock.newCondition();// A线程专属等待队列约定privatestaticfinal Condition condBlock.newCondition();// B线程专属等待队列约定privatestaticint num0;// 当前数字privatestaticboolean isATurntrue;// true: 轮到A初始让A先publicstaticvoidmain(String[]args){// A线程打印偶数newThread(()-{while(num10){// 直到打印完9lock.lock();// 1. 先拿锁try{while(!isATurn){// 2. 用while检查不是我的回合就等condA.await();// 释放锁当前线程A进入condA队列睡觉}// 到这说明轮到我了且重新拿到了锁System.out.println(A打印: num);num;isATurnfalse;// 交给BcondB.signal();// 精确唤醒B只从condB队列拿一个}catch(InterruptedException e){e.printStackTrace();}finally{lock.unlock();// 3. 一定释放锁}}},A).start();// B线程打印奇数newThread(()-{while(num10){lock.lock();try{while(isATurn){// 不是我的回合就等condB.await();// B线程进入condB队列}System.out.println(B打印: num);num;isATurntrue;condA.signal();// 精确唤醒A}catch(InterruptedException e){e.printStackTrace();}finally{lock.unlock();}}},B).start();}}运行结果完美交替textA打印: 0B打印: 1A打印: 2B打印: 3…B打印: 9为什么能精确唤醒不是Condition“认人”而是我们约定A只在condA等B只在condB等。signal()只去对应队列叫醒人不会吵醒另一边。在实际项目中的应用阻塞队列Java的ArrayBlockingQueue就是用一个Lock 两个Condition实现的notEmpty所有消费者共享的等待队列队列空时await。notFull所有生产者共享的等待队列队列满时await。生产后notEmpty.signal()只唤醒一个消费者。消费后notFull.signal()只唤醒一个生产者。多生产者/多消费者时它们共享同一个Condition队列signal()只唤醒一个就够了——超级高效3. 两种方式对比总结特性synchronized wait/notifyLock Condition等待队列只有一个所有线程混一起可以多个独立队列精确唤醒唤醒方式notify随机常用notifyAll惊群signal精确只唤醒需要的功能基础支持超时、中断、公平锁等性能一般高并发下更好使用难度简单自动加解锁稍复杂手动unlock推荐场景简单同步生产者消费者、阻塞队列、高并发结论新项目直接用Lock Condition老方式只用来理解历史。希望这篇文章让你对等待唤醒机制不再迷糊如果你有疑问或者想看生产者消费者的完整代码欢迎留言讨论点赞 收藏 关注三连支持一下呗

需要专业的网站建设服务?

联系我们获取免费的网站建设咨询和方案报价,让我们帮助您实现业务目标

立即咨询