简介ConditionObject 是 AQS 的内部类AQS 有两套队列同步队列sync queue抢锁失败的线程双向链表条件队列condition queue调用 await() 后进入该队列单向链表只属于当前 Conditionawaitpublicfinalvoidawait()throwsInterruptedException{// 1. 如果线程已经被中断直接抛中断异常if(Thread.interrupted())thrownewInterruptedException();// 2. 将当前线程封装成 CONDITION 节点加入【条件队列】NodenodeaddConditionWaiter();// 3. 完全释放当前持有的独占锁返回释放前的state值重入锁计数longsavedStatefullyRelease(node);// 中断标记0无中断1唤醒后中断2等待时中断intinterruptMode0;// 4. 循环判断节点是否还在条件队列// 只有被signal()节点才会移出条件队列进入同步队列退出循环while(!isOnSyncQueue(node)){// 挂起当前线程阻塞在这里LockSupport.park(this);// 5. 被唤醒后检查是否在等待过程中发生中断if((interruptModecheckInterruptWhileWaiting(node))!0)break;}// 6. 退出循环说明节点已进入同步队列自旋阻塞获取锁// acquireQueued死循环抢锁拿到锁才返回返回true代表抢锁期间被中断if(acquireQueued(node,savedState)interruptMode!THROW_IE)interruptModeREINTERRUPT;// 7. 清理条件队列中已取消的节点if(node.nextWaiter!null)unlinkCancelledWaiters();// 8. 根据中断模式处理中断异常if(interruptMode!0)reportInterruptAfterWait(interruptMode);}addConditionWaiter条件队列是单向链表只用 nextWaiter节点标记 waitStatus CONDITION代表当前在条件队列privateNodeaddConditionWaiter(){NodetlastWaiter;// 清理尾部已经取消等待的节点if(t!nullt.waitStatus!Node.CONDITION){unlinkCancelledWaiters();tlastWaiter;}// 创建等待状态为 CONDITION 的新节点NodenodenewNode(Thread.currentThread(),Node.CONDITION);// 尾插法入队if(tnull)firstWaiternode;elset.nextWaiternode;lastWaiternode;returnnode;}fullyReleaseawait() 必须持有 Lock否则 release 失败抛异常和 wait() 必须在 synchronized 内一致一次性释放所有重入次数完全让出锁其他线程可以获取锁执行 signal()privatelongfullyRelease(Nodenode){booleanfailedtrue;try{// 获取当前锁重入次数 statelongsavedStategetState();// release 完全释放锁state置0if(release(savedState)){failedfalse;returnsavedState;}else{// 没持有锁就调用await抛非法监视器异常thrownewIllegalMonitorStateException();}}finally{if(failed)node.waitStatusNode.CANCELLED;}}isOnSyncQueuefinalbooleanisOnSyncQueue(Nodenode){// 条件队列节点 waitStatusCONDITION一定不在同步队列if(node.waitStatusNode.CONDITION||node.prevnull)returnfalse;// 同步队列节点一定有后继if(node.next!null)returntrue;// 兜底从同步队列尾部反向查找returnfindNodeFromTail(node);}signal校验当前线程持有锁取出条件队列头节点CAS 清除 CONDITION 状态调用 enq() 将节点插入同步队列若同步队列前驱节点需要唤醒unpark 目标线程被 unpark 的线程回到 await 的 while 循环发现 isOnSyncQueuetrue退出循环抢锁。publicfinalvoidsignal(){// 校验当前线程持有独占锁if(!isHeldExclusively())thrownewIllegalMonitorStateException();NodefirstfirstWaiter;if(first!null)doSignal(first);}privatevoiddoSignal(Nodefirst){do{// 头节点出条件队列if((firstWaiterfirst.nextWaiter)null)lastWaiternull;first.nextWaiternull;// 将条件节点转为同步节点加入同步队列}while(!transferForSignal(first)(firstfirstWaiter)!null);}// 核心条件队列节点 → 同步队列finalbooleantransferForSignal(Nodenode){// 清除 CONDITION 标记失败说明节点已取消if(!compareAndSetWaitStatus(node,Node.CONDITION,0))returnfalse;// 加入AQS同步队列尾部Nodepenq(node);intwsp.waitStatus;// 前驱节点取消或者CAS设置SIGNAL失败直接唤醒当前线程// 如果前驱作废 / CAS 设置 SIGNAL 失败意味着无法依靠前驱被动唤醒当前线程为了避免线程永久阻塞只能立刻主动 unpark 兜底让线程进入 acquireQueued 重新整理队列、绑定合法可唤醒的前驱if(ws0||!compareAndSetWaitStatus(p,ws,Node.SIGNAL))LockSupport.unpark(node.thread);returntrue;}总结完整流程condition.await() → addConditionWaiter() 加入条件队列 → fullyRelease() 释放锁 → while (!isOnSyncQueue(node)) LockSupport.park() 等待signal signal() → transferForSignal() 将节点移入同步队列 → unpark唤醒线程 回到await循环退出while → acquireQueued(node, savedState) 自旋抢锁 1. 循环尝试获取锁 2. 抢不到则设置前驱SIGNAL并park 3. 抢到锁后返回是否中断 → 根据返回的interrupted处理中断异常