1. JUC核心概念与设计哲学Java Util Concurrent简称JUC是Java 5引入的标准库扩展包位于java.util.concurrent路径下。这个库的诞生直接解决了传统多线程编程中的三大痛点线程生命周期管理复杂、共享资源访问控制困难以及并发任务协调效率低下。JUC的设计哲学体现在三个维度上原子性Atomic通过CASCompare-And-Swap指令实现无锁编程典型如AtomicInteger等原子类可见性Visibility基于happens-before原则的内存可见性保证有序性Ordering禁止指令重排序的内存屏障机制关键认知JUC不是简单的工具集合而是一套完整的并发编程范式。它用AQSAbstractQueuedSynchronizer作为基础构建块衍生出CountDownLatch、CyclicBarrier等高级同步器。2. 核心组件深度解析2.1 线程池体系ThreadPoolExecutor是JUC线程池的核心实现其构造参数包含public ThreadPoolExecutor( int corePoolSize, // 常驻线程数 int maximumPoolSize, // 最大线程数 long keepAliveTime, // 空闲线程存活时间 TimeUnit unit, // 时间单位 BlockingQueueRunnable workQueue, // 任务队列 ThreadFactory threadFactory, // 线程工厂 RejectedExecutionHandler handler // 拒绝策略 )四种拒绝策略对比策略类行为特征适用场景AbortPolicy直接抛出RejectedExecutionException需要严格保证任务不丢失CallerRunsPolicy由提交线程直接执行被拒绝任务适合能容忍延迟的场景DiscardPolicy静默丢弃被拒绝任务允许丢任务的非关键业务DiscardOldestPolicy丢弃队列中最老的任务适合时效性强的任务2.2 并发集合类ConcurrentHashMap在JDK8中的重大改进抛弃分段锁采用NodeCASsynchronized实现当链表长度8时转为红黑树size()方法改用基础计数器BaseCounter与Hashtable的性能对比测试单位ops/ms线程数ConcurrentHashMapHashtable412,3453,210811,9871,4561610,2348922.3 同步工具类CountDownLatch与CyclicBarrier的差异CountDownLatch不可重置适合一次性等待场景如服务启动CyclicBarrier可重复使用适合多阶段任务同步如批量处理Semaphore的两种模式公平模式按申请顺序获取许可非公平模式允许插队吞吐量更高3. 高级特性实战3.1 CompletableFuture组合编程创建异步任务的四种方式// 1. 使用默认线程池 CompletableFuture.runAsync(() - System.out.println(Task1)); // 2. 指定自定义线程池 ExecutorService pool Executors.newCachedThreadPool(); CompletableFuture.supplyAsync(() - Result, pool); // 3. 已完成Future CompletableFuture.completedFuture(Immediate); // 4. 异常处理示例 CompletableFuture.supplyAsync(() - 1/0) .exceptionally(ex - { System.out.println(Error: ex.getMessage()); return 0; });任务链式组合CompletableFuture.supplyAsync(() - queryFromDB()) .thenApplyAsync(result - transformData(result)) .thenAcceptAsync(result - saveToCache(result)) .thenRun(() - cleanUp());3.2 Fork/Join框架优化工作窃取Work-Stealing算法要点每个工作线程维护双端队列空闲线程从其他队列尾部偷任务最佳实践任务粒度控制在100-10000次基本操作斐波那契数列实现示例class Fibonacci extends RecursiveTaskInteger { final int n; Fibonacci(int n) { this.n n; } protected Integer compute() { if (n 1) return n; Fibonacci f1 new Fibonacci(n - 1); f1.fork(); Fibonacci f2 new Fibonacci(n - 2); return f2.compute() f1.join(); } }4. 生产环境问题排查4.1 线程池死锁检测典型死锁场景ExecutorService pool Executors.newSingleThreadExecutor(); FutureString future pool.submit(() - { FutureString inner pool.submit(() - inner); // 死锁点 return inner.get(); }); System.out.println(future.get());诊断方案使用jstack获取线程dump查找BLOCKED状态的线程分析锁持有关系链4.2 内存泄漏排查ConcurrentHashMap使用不当示例MapKey, Value cache new ConcurrentHashMap(); Key key new Key(); // 没有重写equals/hashCode cache.put(key, new Value()); key null; // 键对象无法被GC回收解决方案使用WeakReference作为键定期执行cleanUp操作考虑使用Caffeine等专业缓存库5. 性能优化实战5.1 锁优化技巧锁粒度优化对比// 粗粒度锁 synchronized(this) { // 全部共享变量操作 } // 细粒度锁 Object lock1 new Object(); Object lock2 new Object(); synchronized(lock1) { /* 操作变量A */ } synchronized(lock2) { /* 操作变量B */ }锁升级过程图示需文字描述无锁状态初始对象状态偏向锁第一个线程访问时记录线程ID轻量级锁出现竞争时升级为CAS自旋重量级锁自旋超过阈值默认10次后阻塞5.2 并发计数器选型四种计数器性能对比单位ns/op类型1线程4线程8线程synchronized15120450ReentrantLock2090320AtomicLong560580LongAdder82550经验法则低竞争用Atomic高竞争用LongAdder需要条件等待用Lock6. JUC底层机制揭秘6.1 AQS实现原理AbstractQueuedSynchronizer核心结构// 等待队列节点 static final class Node { volatile int waitStatus; volatile Node prev; volatile Node next; volatile Thread thread; Node nextWaiter; } // 关键方法 public final void acquire(int arg) { if (!tryAcquire(arg) acquireQueued(addWaiter(Node.EXCLUSIVE), arg)) selfInterrupt(); }状态流转示意图文字版线程调用tryAcquire尝试获取锁失败后创建Node加入CLH队列尾部进入自旋检查前驱节点状态前驱成为头节点时再次尝试获取获取成功后将自身设为头节点6.2 CAS底层实现HotSpot的CAS实现路径Java代码调用Unsafe.compareAndSwapIntJVM内联汇编调用cmpxchg指令CPU锁缓存行MESI协议返回比较结果ABA问题解决方案AtomicStampedReferenceInteger ref new AtomicStampedReference(100, 0); int stamp ref.getStamp(); ref.compareAndSet(100, 101, stamp, stamp1);7. 新版特性演进7.1 JDK12新增特性Contended注解优化伪共享jdk.internal.vm.annotation.Contended class Counter { private volatile long value1; private volatile long value2; }效果验证默认情况两个变量可能在同一缓存行使用Contended后强制隔离到不同缓存行性能提升高竞争场景可达300%7.2 Project Loom前瞻虚拟线程使用示例try (var executor Executors.newVirtualThreadPerTaskExecutor()) { IntStream.range(0, 10_000) .forEach(i - executor.submit(() - { Thread.sleep(Duration.ofSeconds(1)); return i; })); }与传统线程对比优势指标平台线程虚拟线程内存占用1MB/线程1KB/线程创建开销约1ms约1μs上下文切换涉及内核纯用户态8. 最佳实践总结8.1 线程池配置公式IO密集型任务线程数 CPU核心数 * (1 平均等待时间/平均计算时间)计算密集型任务线程数 CPU核心数 1防止偶发停顿动态调整策略ThreadPoolExecutor executor new ThreadPoolExecutor(...); executor.setCorePoolSize(newSize); // 运行时调整8.2 锁选择决策树是否需要等待条件 → 是用ReentrantLock是否读多写少 → 是用ReadWriteLock是否短期持有 → 是用synchronized是否无竞争场景 → 是用CAS原子类默认选择StampedLock乐观读9. 常见面试问题剖析9.1 AQS相关问题高频考点为什么AQS采用CLH队列原生的CLH适合自旋锁改造后支持阻塞唤醒机制通过前驱节点状态减少竞争共享模式与独占模式区别共享Semaphore/CountDownLatch独占ReentrantLock差异主要在tryAcquire实现9.2 ConcurrentHashMap演进版本对比要点特性JDK7JDK8结构分段数组链表数组链表/红黑树锁粒度段锁桶级别锁size()分段统计基础计数器迭代器弱一致性弱一致性增强10. 诊断工具链10.1 JConsole监控关键监控项线程页签查看活动线程数死锁检测按钮ThreadPoolExecutor指标ActiveCountQueueSizeCompletedTaskCount10.2 Arthas高级诊断常用命令示例# 查看线程堆栈 thread -n 5 # 监控方法调用 watch java.util.concurrent.ConcurrentHashMap putValue # 追踪锁竞争 monitor java.util.concurrent.locks.ReentrantLock lock10.3 JFR深度分析飞行记录配置示例java -XX:StartFlightRecordingduration60s,\ filenamerecording.jfr,\ settingsprofile MyApp关键事件类型jdk.Contention锁竞争事件jdk.ThreadPark线程阻塞事件jdk.CPULoadCPU负载数据