1. 从“八股文”到实战为什么多线程面试题总让人头疼如果你正在准备Java相关的技术面试或者已经是一位有经验的开发者那么“多线程”这三个字大概率会触发你大脑里某个区域的警报。它几乎是所有中高级Java岗位面试的必考项从基础概念到并发工具再到线上问题的排查层层递进没有尽头。网络上充斥着海量的“Java多线程面试题大全”很多人戏称其为“八股文”靠死记硬背来应付。但真正在项目中一个不起眼的并发问题就可能让服务半夜告警排查起来犹如大海捞针。我经历过很多次面试也面试过很多人。我发现一个有趣的现象能把synchronized和ReentrantLock区别背得滚瓜烂熟的人未必能说清楚在某个高并发场景下到底该选哪个以及为什么。能画出Thread生命周期状态图的人面对一个线程池任务堆积导致CPU飙升的问题可能依然无从下手。这中间的鸿沟就在于“知道”和“理解并能在实战中运用”之间的差距。所以这篇内容我不想再罗列一份冷冰冰的、有标准答案的“题库”。我想和你聊聊在我这些年的开发、面试和解决问题过程中那些关于Java多线程最核心、最容易被问到也最考验功底的“活”的知识点。我们会绕过那些简单的概念复述直接切入到原理、设计权衡和实战场景中。无论你是正在备战面试还是想巩固自己的并发知识体系希望这些基于实战的思考和总结能给你带来一些不一样的视角。2. 线程安全的核心不止是synchronized和volatile当面试官问“如何保证线程安全”时synchronized和volatile通常是第一个跃入脑海的答案。但如果你只回答这两个可能就错过了展示深度的机会。线程安全的本质是在共享、可变的状态上进行正确的管理。我们可以从几个层面来拆解。2.1 无状态与不可变对象最优雅的解决方案在讨论复杂的锁机制之前首先要树立一个观念最好的线程安全策略就是避免共享状态。无状态对象对象本身不包含任何成员变量或者只有常量。所有操作都依赖于参数和局部变量。例如一个只包含静态工具方法的StringUtils类或者一个Servlet如果它不包含实例变量。这是最安全的因为根本没有需要保护的数据。不可变对象对象一旦被创建其状态所有字段就不能再被修改。典型的例子就是String、Integer等包装类。在Java中实现一个不可变类需要将类声明为final防止被继承和重写方法。将所有字段声明为private final。不提供任何可以修改对象状态的方法setter。如果字段是引用类型如集合确保在构造函数和getter中返回的是该字段的防御性拷贝defensive copy而不是原始引用。注意很多人会忽略第4点。如果你的不可变类有一个ListString字段你在构造函数中直接this.list inputList;那么外部调用者仍然可以通过修改inputList来改变你这个“不可变”对象的状态。正确的做法是this.list Collections.unmodifiableList(new ArrayList(inputList));。在实战中优先考虑能否将设计转化为无状态或不可变对象能极大地简化并发模型这是比加锁更高级的思维。2.2synchronized的深度剖析从字节码到锁升级synchronized是Java内置的锁使用简单但底层机制并不简单。它不仅仅是一个关键字。锁存储在哪儿每个Java对象在堆内存中都有一个对象头Object Header其中一部分叫做Mark Word它就用来存储锁信息。这就是为什么Java中“任何对象都可以作为锁”的原因。锁的升级过程偏向锁 - 轻量级锁 - 重量级锁这是synchronized为了在无竞争和竞争情况下平衡性能而做的优化理解这个过程对性能调优很有帮助。无锁状态一个新对象默认处于无锁状态。偏向锁当第一个线程访问同步块时JVM会将对象头中的Mark Word通过CAS操作记录下这个线程的ID并将锁标志位改为偏向模式。之后这个线程再进入和退出同步块时不需要进行CAS加锁解锁只需简单检查Mark Word里是否存储着自己的线程ID。这适用于始终只有一个线程访问同步块的场景能消除同步原语的开销。轻量级锁当有第二个线程尝试获取锁时发生竞争偏向锁就会升级为轻量级锁。JVM会在当前线程的栈帧中创建一个名为锁记录Lock Record的空间并将对象头的Mark Word复制过去。然后尝试用CAS将对象头的Mark Word替换为指向锁记录的指针。如果成功当前线程获得锁如果失败表示有其他线程竞争线程会通过自旋循环尝试的方式等待一小段时间。重量级锁如果轻量级锁竞争失败且自旋也未能获取到锁或者自旋次数超过阈值锁就会升级为重量级锁。此时未获得锁的线程会被挂起进入阻塞状态等待操作系统调度后续再被唤醒。这个挂起和唤醒的操作涉及到用户态到内核态的切换成本很高。为什么synchronized是“重量级”的这个说法其实有点过时了。在早期版本中synchronized直接对应操作系统的互斥量Mutex每次加锁解锁都要进行系统调用开销巨大。但经过锁升级优化后在无竞争或低竞争的场景下它的性能损耗已经非常小了。它的“重”主要体现在升级到重量级锁后的线程阻塞和唤醒上。与ReentrantLock的对比这是一个经典面试题。ReentrantLock是java.util.concurrent.locks包下的一个类它提供了比synchronized更灵活的功能。特性synchronizedReentrantLock实现机制JVM内置通过monitorenter/monitorexit字节码指令实现。JDK API实现基于AbstractQueuedSynchronizer (AQS)。锁的获取隐式获取和释放进入代码块自动获取退出自动释放。显式调用lock()和unlock()必须在finally块中释放。灵活性较差。锁的获取是阻塞式的无法中断等待。灵活。支持尝试非阻塞获取(tryLock())、可中断获取(lockInterruptibly())、超时获取(tryLock(long, TimeUnit))。公平性非公平锁。两者都可选构造函数传入true可创建公平锁但通常性能较差。条件队列通过wait(),notify(),notifyAll()与对象监视器绑定一个锁只能有一个等待队列。可以绑定多个Condition对象实现更精细的线程等待/唤醒如生产者-消费者模型。性能在低竞争下经过优化后性能很好。在高竞争下由于其更复杂的逻辑和灵活性可能略有优势但差异不大。如何选择优先使用synchronized代码简洁不易出错自动释放锁在绝大多数业务并发场景下性能足够。这是默认选择。考虑使用ReentrantLock当你需要其高级特性时比如尝试获取锁、可中断的锁获取、公平锁、或者需要绑定多个条件变量Condition来实现复杂的同步逻辑如阻塞队列。2.3volatile的可见性与有序性内存屏障的魔法volatile关键字保证了两件事可见性和禁止指令重排序。但它不保证原子性。可见性当一个线程修改了一个volatile变量的值新值会立即被刷新到主内存。同时其他线程中关于该变量的缓存行会失效迫使它们必须去主内存读取最新值。这通过底层CPU的缓存一致性协议如MESI和内存屏障指令来实现。禁止指令重排序编译器、运行时和处理器为了优化性能可能会对指令进行重排序。volatile通过插入内存屏障Memory Barrier来禁止这种重排序保证了volatile变量读写操作的有序性。一个经典的例子是双重检查锁定DCL单例模式public class Singleton { private static volatile Singleton instance; // 必须使用volatile private Singleton() {} public static Singleton getInstance() { if (instance null) { // 第一次检查 synchronized (Singleton.class) { if (instance null) { // 第二次检查 instance new Singleton(); // 关键 } } } return instance; } }为什么instance必须用volatile修饰因为instance new Singleton();这行代码并非原子操作它大致分为三步分配内存空间。初始化Singleton对象。将instance引用指向这块内存。如果没有volatile步骤2和3可能被重排序。那么可能出现线程A执行到步骤3instance已不为null但对象未初始化此时线程B进入第一个if (instance null)判断发现不为null直接返回了一个未初始化完成的对象从而导致程序错误。volatile通过禁止重排序确保了“写”操作步骤3一定发生在“读”操作之前解决了这个问题。3. JUC并发工具库不要重复造轮子java.util.concurrent(JUC) 包是Java并发编程的利器。面试中对于ConcurrentHashMap、CopyOnWriteArrayList、CountDownLatch、CyclicBarrier、Semaphore等工具不能仅仅停留在“知道它们线程安全”的层面。3.1ConcurrentHashMap的演进从分段锁到CAS这是高频考点。它的线程安全实现经历了重大变化。JDK 1.7及之前分段锁Segment它将整个哈希表分成一个个小的Segment继承自ReentrantLock每个Segment独立加锁。put操作时只需要锁住对应的Segment其他Segment仍然可以被访问提高了并发度。可以理解为一种“锁细化”的策略。但缺点是结构复杂并且在查询需要获取所有Segment的锁时如size()效率不高。JDK 1.8及之后CAS synchronized这是目前的主流实现设计非常精妙。数据结构采用了和HashMap类似的数组 链表/红黑树结构。put操作首先根据key的hash找到数组下标如果该位置为null则尝试用CAS操作将新节点放入。成功则返回。如果CAS失败说明有其他线程抢先插入了或者该位置已有节点链表或树则对这个桶bucket的头节点使用synchronized进行加锁然后在锁内进行链表或红黑树的插入操作。get操作全程无锁因为Node的val和next都用了volatile修饰保证了可见性。通过Unsafe类提供的原子性操作来读取数据。这种设计的好处是将锁的粒度从“段”细化到了“单个桶”并发度更高并且在读多写少的场景下读操作完全无锁性能极佳。与Hashtable和Collections.synchronizedMap的对比Hashtable所有方法都用synchronized修饰是对象级别的锁并发度极低基本已被淘汰。Collections.synchronizedMap(new HashMap())它返回一个包装类内部使用一个普通的HashMap和一个互斥锁Mutex所有方法都先获取这个锁。性能同样很差。结论在高并发场景下无脑选ConcurrentHashMap。3.2CountDownLatchvsCyclicBarrier一次性栅栏与可循环栅栏两者都用于线程间的协调但侧重点不同。CountDownLatch倒计时门闩核心思想一个或多个线程等待其他一组线程完成操作。它像一个计数器初始化时设定一个数值N。其他线程完成任务后调用countDown()计数器减1。调用await()的线程会阻塞直到计数器减为0。特点一次性。计数器减到0后就不能再重置。典型场景主线程等待所有子线程初始化完成后再执行。模拟并发测试让所有测试线程同时开始执行。多个线程等待一个事件的发生如服务启动完成。CyclicBarrier循环屏障核心思想让一组线程互相等待直到所有线程都到达一个公共的屏障点然后这一组线程再继续执行。它也可以接受一个Runnable参数作为屏障动作barrierAction当所有线程到达屏障后由最后一个到达的线程执行这个动作。特点可循环使用。当所有等待线程被释放后屏障会自动重置可以再次使用。典型场景多线程计算任务最后合并计算结果。迭代计算每一轮迭代都需要所有线程完成当前轮次的计算。简单记忆CountDownLatch是一个线程或几个等N个线程干完事CyclicBarrier是N个线程相互等等大家都到齐了再一起干下一件事。3.3ThreadLocal线程隔离的利器与内存泄漏的坑ThreadLocal提供了线程局部变量每个线程都有自己独立的变量副本避免了共享带来的线程安全问题。它的典型应用场景是数据库连接、Session管理等需要与线程绑定的资源。原理 每个Thread对象内部都有一个ThreadLocal.ThreadLocalMap类型的变量threadLocals。这个Map的key是ThreadLocal实例本身弱引用value是存储的值。当调用ThreadLocal的set(T value)方法时实际上是以当前ThreadLocal实例为key将value存入当前线程的threadLocals这个Map中。内存泄漏风险 这是ThreadLocal最著名的坑。在ThreadLocalMap中key即ThreadLocal对象是弱引用而value是强引用。如果ThreadLocal外部强引用被置为null那么在下一次GC时这个ThreadLocal对象就会被回收Map中的key就变成了null。但是value由于是强引用只要当前线程还在运行例如使用了线程池线程会复用这个Entry就无法被回收导致value永远无法被访问却又占着内存造成内存泄漏。如何避免养成好习惯每次使用完ThreadLocal后务必调用其remove()方法清理当前线程的Map中对应的Entry。这是最有效的方法。将ThreadLocal变量声明为private static final使其生命周期与类一致避免被意外回收。如果使用了线程池线程会长期存活这个问题会更加严重remove()就更加关键。4. 线程池不只是Executors.newFixedThreadPool线程池是管理和复用线程的核心工具。直接使用Executors的工厂方法如newFixedThreadPool,newCachedThreadPool虽然方便但在生产环境中往往不是最佳选择因为它们隐藏了一些重要的参数细节。4.1 核心参数与工作原理我们需要深入理解ThreadPoolExecutor的构造函数public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueRunnable workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)corePoolSize核心线程数线程池中常驻的线程数量。即使它们空闲也不会被回收除非设置了allowCoreThreadTimeOut。maximumPoolSize最大线程数线程池允许创建的最大线程数。keepAliveTime空闲线程存活时间当线程数超过corePoolSize时多余的空闲线程在等待新任务的最长时间超过这个时间将被终止。workQueue工作队列用于存放等待执行的任务的阻塞队列。这是线程池调优的关键。threadFactory线程工厂用于创建新线程。可以在这里设置线程名、优先级、守护线程等便于监控和排查问题。handler拒绝策略当线程池和队列都满了无法处理新任务时采取的应对策略。线程池的工作流程务必理解提交一个任务。如果当前运行的线程数 corePoolSize则创建新线程来执行任务即使有空闲线程。如果运行的线程数 corePoolSize则将任务放入workQueue。如果队列已满且运行的线程数 maximumPoolSize则创建新的非核心线程来执行任务。如果队列已满且运行的线程数已达到maximumPoolSize则触发拒绝策略handler。4.2 队列与拒绝策略的选择工作队列workQueue的选择SynchronousQueue一个不存储元素的队列。每个插入操作必须等待另一个线程的移除操作。newCachedThreadPool使用了它。它要求线程池有足够的增长能力maximumPoolSize为Integer.MAX_VALUE否则很容易触发拒绝策略。适用于任务量瞬间暴涨的场景但需警惕线程数无限增长。LinkedBlockingQueue无界队列newFixedThreadPool和newSingleThreadExecutor默认使用它。队列长度理论上是无限的。当所有核心线程都在忙时新任务会在队列中等待。这会导致队列无限堆积最终可能引发OOM。生产环境慎用无界队列。ArrayBlockingQueue有界队列需要指定队列容量。这是生产环境的推荐选择之一。它能在队列满时触发创建新线程如果未达最大线程数或拒绝策略提供了背压back-pressure能力。PriorityBlockingQueue优先级队列可以按优先级执行任务。拒绝策略RejectedExecutionHandlerAbortPolicy默认直接抛出RejectedExecutionException异常。CallerRunsPolicy由调用者线程提交任务的线程自己来执行这个任务。这提供了一个简单的反馈机制会降低新任务的提交速度。DiscardPolicy默默丢弃无法处理的任务不抛异常。DiscardOldestPolicy丢弃队列中最老的一个任务然后尝试重新提交当前任务。生产环境配置建议 不要直接使用Executors而是根据业务场景手动创建ThreadPoolExecutor。CPU密集型任务如计算、加密线程数建议设置为CPU核心数 1。过多的线程会导致频繁的上下文切换降低性能。IO密集型任务如网络请求、数据库操作线程数可以设置得多一些因为线程大部分时间在等待IO。经验公式CPU核心数 * (1 平均等待时间 / 平均计算时间)。例如如果计算时间与等待时间比为1:2则可设为CPU核心数 * 3。通常可以设置为2 * CPU核心数。使用有界队列如ArrayBlockingQueue并设置一个合理的容量。定义有意义的线程名前缀方便通过jstack等工具排查问题时识别线程。根据业务重要性选择合适的拒绝策略。对于核心业务可以考虑使用CallerRunsPolicy或自定义策略如将任务持久化到数据库或消息队列稍后重试。4.3 常见问题排查思路任务堆积CPU使用率低很可能是任务处理中有阻塞如慢SQL、外部HTTP调用且线程数配置不足或队列过长。需要分析任务内容优化慢操作或适当增加线程数对于IO密集型。CPU使用率高甚至100%可能是CPU密集型任务线程数设置过多导致大量上下文切换。用top -Hp [pid]和jstack查看线程状态如果大量线程处于RUNNABLE状态且在做计算就需要降低线程数。也可能是代码中存在死循环或低效算法。内存溢出OOM如果使用了无界队列LinkedBlockingQueue任务产生速度持续大于消费速度队列中的任务对象会不断堆积最终撑爆堆内存。这是使用Executors.newFixedThreadPool的典型风险。5. 原子类与CAS无锁并发的基础当面试官问“除了锁还有什么方式保证线程安全”时原子类AtomicInteger,AtomicLong,AtomicReference等是一个重要答案。它们的核心是CASCompare-And-Swap操作。5.1 CAS原理与ABA问题CAS是一种乐观锁机制。它包含三个操作数内存位置V、旧的预期值A、新值B。当且仅当V的值等于A时处理器才会用B更新V的值否则不执行更新。无论是否更新都会返回V的旧值。整个操作是一个原子指令通常由CPU硬件提供如x86的cmpxchg指令。Java通过Unsafe类提供的本地方法如compareAndSwapInt来调用底层CPU的CAS指令。ABA问题 假设一个变量初始值为A。线程1准备用CAS将其改为C它读取到旧值A。此时线程2将值从A改为B然后又从B改回A。接着线程1执行CAS发现当前值仍然是A符合预期于是成功将A改为了C。对于线程1来说它感知不到这个值曾经发生过A-B-A的变化。在某些场景下如链表的头节点这可能带来问题。解决方案AtomicStampedReference和AtomicMarkableReference。它们不仅比较值还比较一个版本号Stamp或标记Mark。每次修改不仅更新值还更新版本号。CAS操作需要同时检查值和版本号是否都符合预期。5.2 原子类的实现与局限以AtomicInteger的incrementAndGet()为例其内部通常是一个自旋循环public final int incrementAndGet() { return unsafe.getAndAddInt(this, valueOffset, 1) 1; } // Unsafe.getAndAddInt 内部类似 public final int getAndAddInt(Object o, long offset, int delta) { int v; do { v getIntVolatile(o, offset); // 获取当前值 } while (!compareAndSwapInt(o, offset, v, v delta)); // CAS失败则循环重试 return v; }优点在低到中度竞争下避免了线程挂起和调度的开销性能比锁好。缺点自旋开销在高竞争环境下如果CAS一直失败线程会长时间循环消耗CPU资源。只能保证一个共享变量的原子操作对于多个变量CAS无法保证其原子性。但可以用AtomicReference将多个变量封装成一个对象来操作。ABA问题已讨论。6. 线上问题排查死锁与线程状态分析理论知识最终要服务于解决问题。线上系统出现性能问题或假死多线程往往是怀疑对象。6.1 死锁的识别与定位死锁的四个必要条件互斥、持有并等待、不可剥夺、循环等待。在Java中最常用jstack命令来定位死锁。使用jstackjstack -l pid thread_dump.txt打开thread_dump.txt文件搜索“deadlock”或“Found one Java-level deadlock:”jstack通常会清晰地指出哪些线程互相等待以及它们各自持有什么锁、在等待什么锁。分析线程堆栈死锁的线程通常会处于BLOCKED状态并且其堆栈信息会显示它在等待某个对象的监视器waiting to lock 0x000000071a2345b0同时持有另一个锁locked 0x000000071a2345a0。通过对比多个线程的持有锁和等待锁就能画出资源等待图找到循环等待链。预防死锁的常见方法避免嵌套锁尽量只获取一个锁。如果必须获取多个确保所有线程以固定的全局顺序获取锁例如总是先锁A再锁B。使用带超时的锁如ReentrantLock.tryLock(long timeout, TimeUnit unit)获取锁失败超时后可以释放已持有的锁并回退重试。静态代码分析工具在代码层面检测潜在的死锁风险。6.2 理解Java线程状态通过jstack看到的线程状态是诊断问题的关键RUNNABLE线程正在JVM中执行但不一定正在占用CPU可能正在等待操作系统调度。BLOCKED线程被阻塞等待进入一个synchronized方法或代码块即等待获取一个监视器锁。这是与WAITING/TIMED_WAITING的关键区别。WAITING线程处于无限期等待状态等待被其他线程显式唤醒。通常由Object.wait()、Thread.join()或LockSupport.park()导致。TIMED_WAITING线程处于限期等待状态。由Thread.sleep(long)、Object.wait(long)、Thread.join(long)等带超时参数的方法导致。TERMINATED线程已执行完毕。一个常见的误解线程在等待IO如读Socket时在jstack中显示什么状态答案是**RUNNABLE**。因为Java线程状态是JVM层面的它只关心线程是否在等待JVM管理的资源如锁。等待底层操作系统IO操作完成对于JVM来说线程仍然是“可运行”的尽管它可能实际上在操作系统层面被挂起。这一点在分析高IO等待的应用时非常重要不要看到大量RUNNABLE线程就以为是CPU计算繁忙。7. Java内存模型JMM与happens-before这是多线程中最抽象、最难理解但也最核心的部分。它定义了线程如何与内存交互以及什么情况下一个线程对共享变量的写操作对另一个线程可见。7.1 为什么需要JMM现代计算机为了性能会有多级缓存CPU L1/L2/L3 Cache这会导致一个核心修改了数据另一个核心可能无法立即看到即可见性问题。此外编译器和处理器会对指令进行重排序以优化性能这可能导致程序执行顺序与代码书写顺序不一致即有序性问题。JMM就是为了在复杂的硬件和编译器优化背景下给程序员提供一个一致的内存可见性保证。7.2happens-before规则JMM通过happens-before规则来阐述内存可见性。如果操作Ahappens-before操作B那么A所做的任何内存修改对B都是可见的。这是一组偏序关系不需要实际的时间先后。几条关键的happens-before规则程序顺序规则在同一个线程中按照代码顺序前面的操作happens-before后面的操作。注意这仅保证单线程内的语义不影响重排序对多线程的可见性。监视器锁规则对一个锁的解锁操作happens-before于后续对这个锁的加锁操作。volatile变量规则对一个volatile变量的写操作happens-before于后续对这个变量的读操作。传递性如果Ahappens-beforeB且Bhappens-beforeC那么Ahappens-beforeC。一个综合例子// 线程A sharedVariable 1; // 普通写 lock.unlock(); // 操作1解锁 // 线程B lock.lock(); // 操作2加锁 int r sharedVariable; // 操作3读根据规则2操作1happens-before操作2。 根据规则1在单线程B内操作2happens-before操作3。 根据规则4传递性操作1happens-before操作3。 因此线程A在解锁前对sharedVariable的写入对线程B在加锁后的读取是可见的。这就是synchronized能保证可见性的底层原理之一。理解JMM和happens-before你就能从原理上明白为什么synchronized、volatile、final等关键字能保证线程安全而不仅仅是记住结论。当你在代码中正确地使用了这些同步机制时JMM会确保你的程序获得预期的内存可见性。 Java多线程实战：从锁机制到JUC并发工具与线程池调优
1. 从“八股文”到实战为什么多线程面试题总让人头疼如果你正在准备Java相关的技术面试或者已经是一位有经验的开发者那么“多线程”这三个字大概率会触发你大脑里某个区域的警报。它几乎是所有中高级Java岗位面试的必考项从基础概念到并发工具再到线上问题的排查层层递进没有尽头。网络上充斥着海量的“Java多线程面试题大全”很多人戏称其为“八股文”靠死记硬背来应付。但真正在项目中一个不起眼的并发问题就可能让服务半夜告警排查起来犹如大海捞针。我经历过很多次面试也面试过很多人。我发现一个有趣的现象能把synchronized和ReentrantLock区别背得滚瓜烂熟的人未必能说清楚在某个高并发场景下到底该选哪个以及为什么。能画出Thread生命周期状态图的人面对一个线程池任务堆积导致CPU飙升的问题可能依然无从下手。这中间的鸿沟就在于“知道”和“理解并能在实战中运用”之间的差距。所以这篇内容我不想再罗列一份冷冰冰的、有标准答案的“题库”。我想和你聊聊在我这些年的开发、面试和解决问题过程中那些关于Java多线程最核心、最容易被问到也最考验功底的“活”的知识点。我们会绕过那些简单的概念复述直接切入到原理、设计权衡和实战场景中。无论你是正在备战面试还是想巩固自己的并发知识体系希望这些基于实战的思考和总结能给你带来一些不一样的视角。2. 线程安全的核心不止是synchronized和volatile当面试官问“如何保证线程安全”时synchronized和volatile通常是第一个跃入脑海的答案。但如果你只回答这两个可能就错过了展示深度的机会。线程安全的本质是在共享、可变的状态上进行正确的管理。我们可以从几个层面来拆解。2.1 无状态与不可变对象最优雅的解决方案在讨论复杂的锁机制之前首先要树立一个观念最好的线程安全策略就是避免共享状态。无状态对象对象本身不包含任何成员变量或者只有常量。所有操作都依赖于参数和局部变量。例如一个只包含静态工具方法的StringUtils类或者一个Servlet如果它不包含实例变量。这是最安全的因为根本没有需要保护的数据。不可变对象对象一旦被创建其状态所有字段就不能再被修改。典型的例子就是String、Integer等包装类。在Java中实现一个不可变类需要将类声明为final防止被继承和重写方法。将所有字段声明为private final。不提供任何可以修改对象状态的方法setter。如果字段是引用类型如集合确保在构造函数和getter中返回的是该字段的防御性拷贝defensive copy而不是原始引用。注意很多人会忽略第4点。如果你的不可变类有一个ListString字段你在构造函数中直接this.list inputList;那么外部调用者仍然可以通过修改inputList来改变你这个“不可变”对象的状态。正确的做法是this.list Collections.unmodifiableList(new ArrayList(inputList));。在实战中优先考虑能否将设计转化为无状态或不可变对象能极大地简化并发模型这是比加锁更高级的思维。2.2synchronized的深度剖析从字节码到锁升级synchronized是Java内置的锁使用简单但底层机制并不简单。它不仅仅是一个关键字。锁存储在哪儿每个Java对象在堆内存中都有一个对象头Object Header其中一部分叫做Mark Word它就用来存储锁信息。这就是为什么Java中“任何对象都可以作为锁”的原因。锁的升级过程偏向锁 - 轻量级锁 - 重量级锁这是synchronized为了在无竞争和竞争情况下平衡性能而做的优化理解这个过程对性能调优很有帮助。无锁状态一个新对象默认处于无锁状态。偏向锁当第一个线程访问同步块时JVM会将对象头中的Mark Word通过CAS操作记录下这个线程的ID并将锁标志位改为偏向模式。之后这个线程再进入和退出同步块时不需要进行CAS加锁解锁只需简单检查Mark Word里是否存储着自己的线程ID。这适用于始终只有一个线程访问同步块的场景能消除同步原语的开销。轻量级锁当有第二个线程尝试获取锁时发生竞争偏向锁就会升级为轻量级锁。JVM会在当前线程的栈帧中创建一个名为锁记录Lock Record的空间并将对象头的Mark Word复制过去。然后尝试用CAS将对象头的Mark Word替换为指向锁记录的指针。如果成功当前线程获得锁如果失败表示有其他线程竞争线程会通过自旋循环尝试的方式等待一小段时间。重量级锁如果轻量级锁竞争失败且自旋也未能获取到锁或者自旋次数超过阈值锁就会升级为重量级锁。此时未获得锁的线程会被挂起进入阻塞状态等待操作系统调度后续再被唤醒。这个挂起和唤醒的操作涉及到用户态到内核态的切换成本很高。为什么synchronized是“重量级”的这个说法其实有点过时了。在早期版本中synchronized直接对应操作系统的互斥量Mutex每次加锁解锁都要进行系统调用开销巨大。但经过锁升级优化后在无竞争或低竞争的场景下它的性能损耗已经非常小了。它的“重”主要体现在升级到重量级锁后的线程阻塞和唤醒上。与ReentrantLock的对比这是一个经典面试题。ReentrantLock是java.util.concurrent.locks包下的一个类它提供了比synchronized更灵活的功能。特性synchronizedReentrantLock实现机制JVM内置通过monitorenter/monitorexit字节码指令实现。JDK API实现基于AbstractQueuedSynchronizer (AQS)。锁的获取隐式获取和释放进入代码块自动获取退出自动释放。显式调用lock()和unlock()必须在finally块中释放。灵活性较差。锁的获取是阻塞式的无法中断等待。灵活。支持尝试非阻塞获取(tryLock())、可中断获取(lockInterruptibly())、超时获取(tryLock(long, TimeUnit))。公平性非公平锁。两者都可选构造函数传入true可创建公平锁但通常性能较差。条件队列通过wait(),notify(),notifyAll()与对象监视器绑定一个锁只能有一个等待队列。可以绑定多个Condition对象实现更精细的线程等待/唤醒如生产者-消费者模型。性能在低竞争下经过优化后性能很好。在高竞争下由于其更复杂的逻辑和灵活性可能略有优势但差异不大。如何选择优先使用synchronized代码简洁不易出错自动释放锁在绝大多数业务并发场景下性能足够。这是默认选择。考虑使用ReentrantLock当你需要其高级特性时比如尝试获取锁、可中断的锁获取、公平锁、或者需要绑定多个条件变量Condition来实现复杂的同步逻辑如阻塞队列。2.3volatile的可见性与有序性内存屏障的魔法volatile关键字保证了两件事可见性和禁止指令重排序。但它不保证原子性。可见性当一个线程修改了一个volatile变量的值新值会立即被刷新到主内存。同时其他线程中关于该变量的缓存行会失效迫使它们必须去主内存读取最新值。这通过底层CPU的缓存一致性协议如MESI和内存屏障指令来实现。禁止指令重排序编译器、运行时和处理器为了优化性能可能会对指令进行重排序。volatile通过插入内存屏障Memory Barrier来禁止这种重排序保证了volatile变量读写操作的有序性。一个经典的例子是双重检查锁定DCL单例模式public class Singleton { private static volatile Singleton instance; // 必须使用volatile private Singleton() {} public static Singleton getInstance() { if (instance null) { // 第一次检查 synchronized (Singleton.class) { if (instance null) { // 第二次检查 instance new Singleton(); // 关键 } } } return instance; } }为什么instance必须用volatile修饰因为instance new Singleton();这行代码并非原子操作它大致分为三步分配内存空间。初始化Singleton对象。将instance引用指向这块内存。如果没有volatile步骤2和3可能被重排序。那么可能出现线程A执行到步骤3instance已不为null但对象未初始化此时线程B进入第一个if (instance null)判断发现不为null直接返回了一个未初始化完成的对象从而导致程序错误。volatile通过禁止重排序确保了“写”操作步骤3一定发生在“读”操作之前解决了这个问题。3. JUC并发工具库不要重复造轮子java.util.concurrent(JUC) 包是Java并发编程的利器。面试中对于ConcurrentHashMap、CopyOnWriteArrayList、CountDownLatch、CyclicBarrier、Semaphore等工具不能仅仅停留在“知道它们线程安全”的层面。3.1ConcurrentHashMap的演进从分段锁到CAS这是高频考点。它的线程安全实现经历了重大变化。JDK 1.7及之前分段锁Segment它将整个哈希表分成一个个小的Segment继承自ReentrantLock每个Segment独立加锁。put操作时只需要锁住对应的Segment其他Segment仍然可以被访问提高了并发度。可以理解为一种“锁细化”的策略。但缺点是结构复杂并且在查询需要获取所有Segment的锁时如size()效率不高。JDK 1.8及之后CAS synchronized这是目前的主流实现设计非常精妙。数据结构采用了和HashMap类似的数组 链表/红黑树结构。put操作首先根据key的hash找到数组下标如果该位置为null则尝试用CAS操作将新节点放入。成功则返回。如果CAS失败说明有其他线程抢先插入了或者该位置已有节点链表或树则对这个桶bucket的头节点使用synchronized进行加锁然后在锁内进行链表或红黑树的插入操作。get操作全程无锁因为Node的val和next都用了volatile修饰保证了可见性。通过Unsafe类提供的原子性操作来读取数据。这种设计的好处是将锁的粒度从“段”细化到了“单个桶”并发度更高并且在读多写少的场景下读操作完全无锁性能极佳。与Hashtable和Collections.synchronizedMap的对比Hashtable所有方法都用synchronized修饰是对象级别的锁并发度极低基本已被淘汰。Collections.synchronizedMap(new HashMap())它返回一个包装类内部使用一个普通的HashMap和一个互斥锁Mutex所有方法都先获取这个锁。性能同样很差。结论在高并发场景下无脑选ConcurrentHashMap。3.2CountDownLatchvsCyclicBarrier一次性栅栏与可循环栅栏两者都用于线程间的协调但侧重点不同。CountDownLatch倒计时门闩核心思想一个或多个线程等待其他一组线程完成操作。它像一个计数器初始化时设定一个数值N。其他线程完成任务后调用countDown()计数器减1。调用await()的线程会阻塞直到计数器减为0。特点一次性。计数器减到0后就不能再重置。典型场景主线程等待所有子线程初始化完成后再执行。模拟并发测试让所有测试线程同时开始执行。多个线程等待一个事件的发生如服务启动完成。CyclicBarrier循环屏障核心思想让一组线程互相等待直到所有线程都到达一个公共的屏障点然后这一组线程再继续执行。它也可以接受一个Runnable参数作为屏障动作barrierAction当所有线程到达屏障后由最后一个到达的线程执行这个动作。特点可循环使用。当所有等待线程被释放后屏障会自动重置可以再次使用。典型场景多线程计算任务最后合并计算结果。迭代计算每一轮迭代都需要所有线程完成当前轮次的计算。简单记忆CountDownLatch是一个线程或几个等N个线程干完事CyclicBarrier是N个线程相互等等大家都到齐了再一起干下一件事。3.3ThreadLocal线程隔离的利器与内存泄漏的坑ThreadLocal提供了线程局部变量每个线程都有自己独立的变量副本避免了共享带来的线程安全问题。它的典型应用场景是数据库连接、Session管理等需要与线程绑定的资源。原理 每个Thread对象内部都有一个ThreadLocal.ThreadLocalMap类型的变量threadLocals。这个Map的key是ThreadLocal实例本身弱引用value是存储的值。当调用ThreadLocal的set(T value)方法时实际上是以当前ThreadLocal实例为key将value存入当前线程的threadLocals这个Map中。内存泄漏风险 这是ThreadLocal最著名的坑。在ThreadLocalMap中key即ThreadLocal对象是弱引用而value是强引用。如果ThreadLocal外部强引用被置为null那么在下一次GC时这个ThreadLocal对象就会被回收Map中的key就变成了null。但是value由于是强引用只要当前线程还在运行例如使用了线程池线程会复用这个Entry就无法被回收导致value永远无法被访问却又占着内存造成内存泄漏。如何避免养成好习惯每次使用完ThreadLocal后务必调用其remove()方法清理当前线程的Map中对应的Entry。这是最有效的方法。将ThreadLocal变量声明为private static final使其生命周期与类一致避免被意外回收。如果使用了线程池线程会长期存活这个问题会更加严重remove()就更加关键。4. 线程池不只是Executors.newFixedThreadPool线程池是管理和复用线程的核心工具。直接使用Executors的工厂方法如newFixedThreadPool,newCachedThreadPool虽然方便但在生产环境中往往不是最佳选择因为它们隐藏了一些重要的参数细节。4.1 核心参数与工作原理我们需要深入理解ThreadPoolExecutor的构造函数public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueRunnable workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)corePoolSize核心线程数线程池中常驻的线程数量。即使它们空闲也不会被回收除非设置了allowCoreThreadTimeOut。maximumPoolSize最大线程数线程池允许创建的最大线程数。keepAliveTime空闲线程存活时间当线程数超过corePoolSize时多余的空闲线程在等待新任务的最长时间超过这个时间将被终止。workQueue工作队列用于存放等待执行的任务的阻塞队列。这是线程池调优的关键。threadFactory线程工厂用于创建新线程。可以在这里设置线程名、优先级、守护线程等便于监控和排查问题。handler拒绝策略当线程池和队列都满了无法处理新任务时采取的应对策略。线程池的工作流程务必理解提交一个任务。如果当前运行的线程数 corePoolSize则创建新线程来执行任务即使有空闲线程。如果运行的线程数 corePoolSize则将任务放入workQueue。如果队列已满且运行的线程数 maximumPoolSize则创建新的非核心线程来执行任务。如果队列已满且运行的线程数已达到maximumPoolSize则触发拒绝策略handler。4.2 队列与拒绝策略的选择工作队列workQueue的选择SynchronousQueue一个不存储元素的队列。每个插入操作必须等待另一个线程的移除操作。newCachedThreadPool使用了它。它要求线程池有足够的增长能力maximumPoolSize为Integer.MAX_VALUE否则很容易触发拒绝策略。适用于任务量瞬间暴涨的场景但需警惕线程数无限增长。LinkedBlockingQueue无界队列newFixedThreadPool和newSingleThreadExecutor默认使用它。队列长度理论上是无限的。当所有核心线程都在忙时新任务会在队列中等待。这会导致队列无限堆积最终可能引发OOM。生产环境慎用无界队列。ArrayBlockingQueue有界队列需要指定队列容量。这是生产环境的推荐选择之一。它能在队列满时触发创建新线程如果未达最大线程数或拒绝策略提供了背压back-pressure能力。PriorityBlockingQueue优先级队列可以按优先级执行任务。拒绝策略RejectedExecutionHandlerAbortPolicy默认直接抛出RejectedExecutionException异常。CallerRunsPolicy由调用者线程提交任务的线程自己来执行这个任务。这提供了一个简单的反馈机制会降低新任务的提交速度。DiscardPolicy默默丢弃无法处理的任务不抛异常。DiscardOldestPolicy丢弃队列中最老的一个任务然后尝试重新提交当前任务。生产环境配置建议 不要直接使用Executors而是根据业务场景手动创建ThreadPoolExecutor。CPU密集型任务如计算、加密线程数建议设置为CPU核心数 1。过多的线程会导致频繁的上下文切换降低性能。IO密集型任务如网络请求、数据库操作线程数可以设置得多一些因为线程大部分时间在等待IO。经验公式CPU核心数 * (1 平均等待时间 / 平均计算时间)。例如如果计算时间与等待时间比为1:2则可设为CPU核心数 * 3。通常可以设置为2 * CPU核心数。使用有界队列如ArrayBlockingQueue并设置一个合理的容量。定义有意义的线程名前缀方便通过jstack等工具排查问题时识别线程。根据业务重要性选择合适的拒绝策略。对于核心业务可以考虑使用CallerRunsPolicy或自定义策略如将任务持久化到数据库或消息队列稍后重试。4.3 常见问题排查思路任务堆积CPU使用率低很可能是任务处理中有阻塞如慢SQL、外部HTTP调用且线程数配置不足或队列过长。需要分析任务内容优化慢操作或适当增加线程数对于IO密集型。CPU使用率高甚至100%可能是CPU密集型任务线程数设置过多导致大量上下文切换。用top -Hp [pid]和jstack查看线程状态如果大量线程处于RUNNABLE状态且在做计算就需要降低线程数。也可能是代码中存在死循环或低效算法。内存溢出OOM如果使用了无界队列LinkedBlockingQueue任务产生速度持续大于消费速度队列中的任务对象会不断堆积最终撑爆堆内存。这是使用Executors.newFixedThreadPool的典型风险。5. 原子类与CAS无锁并发的基础当面试官问“除了锁还有什么方式保证线程安全”时原子类AtomicInteger,AtomicLong,AtomicReference等是一个重要答案。它们的核心是CASCompare-And-Swap操作。5.1 CAS原理与ABA问题CAS是一种乐观锁机制。它包含三个操作数内存位置V、旧的预期值A、新值B。当且仅当V的值等于A时处理器才会用B更新V的值否则不执行更新。无论是否更新都会返回V的旧值。整个操作是一个原子指令通常由CPU硬件提供如x86的cmpxchg指令。Java通过Unsafe类提供的本地方法如compareAndSwapInt来调用底层CPU的CAS指令。ABA问题 假设一个变量初始值为A。线程1准备用CAS将其改为C它读取到旧值A。此时线程2将值从A改为B然后又从B改回A。接着线程1执行CAS发现当前值仍然是A符合预期于是成功将A改为了C。对于线程1来说它感知不到这个值曾经发生过A-B-A的变化。在某些场景下如链表的头节点这可能带来问题。解决方案AtomicStampedReference和AtomicMarkableReference。它们不仅比较值还比较一个版本号Stamp或标记Mark。每次修改不仅更新值还更新版本号。CAS操作需要同时检查值和版本号是否都符合预期。5.2 原子类的实现与局限以AtomicInteger的incrementAndGet()为例其内部通常是一个自旋循环public final int incrementAndGet() { return unsafe.getAndAddInt(this, valueOffset, 1) 1; } // Unsafe.getAndAddInt 内部类似 public final int getAndAddInt(Object o, long offset, int delta) { int v; do { v getIntVolatile(o, offset); // 获取当前值 } while (!compareAndSwapInt(o, offset, v, v delta)); // CAS失败则循环重试 return v; }优点在低到中度竞争下避免了线程挂起和调度的开销性能比锁好。缺点自旋开销在高竞争环境下如果CAS一直失败线程会长时间循环消耗CPU资源。只能保证一个共享变量的原子操作对于多个变量CAS无法保证其原子性。但可以用AtomicReference将多个变量封装成一个对象来操作。ABA问题已讨论。6. 线上问题排查死锁与线程状态分析理论知识最终要服务于解决问题。线上系统出现性能问题或假死多线程往往是怀疑对象。6.1 死锁的识别与定位死锁的四个必要条件互斥、持有并等待、不可剥夺、循环等待。在Java中最常用jstack命令来定位死锁。使用jstackjstack -l pid thread_dump.txt打开thread_dump.txt文件搜索“deadlock”或“Found one Java-level deadlock:”jstack通常会清晰地指出哪些线程互相等待以及它们各自持有什么锁、在等待什么锁。分析线程堆栈死锁的线程通常会处于BLOCKED状态并且其堆栈信息会显示它在等待某个对象的监视器waiting to lock 0x000000071a2345b0同时持有另一个锁locked 0x000000071a2345a0。通过对比多个线程的持有锁和等待锁就能画出资源等待图找到循环等待链。预防死锁的常见方法避免嵌套锁尽量只获取一个锁。如果必须获取多个确保所有线程以固定的全局顺序获取锁例如总是先锁A再锁B。使用带超时的锁如ReentrantLock.tryLock(long timeout, TimeUnit unit)获取锁失败超时后可以释放已持有的锁并回退重试。静态代码分析工具在代码层面检测潜在的死锁风险。6.2 理解Java线程状态通过jstack看到的线程状态是诊断问题的关键RUNNABLE线程正在JVM中执行但不一定正在占用CPU可能正在等待操作系统调度。BLOCKED线程被阻塞等待进入一个synchronized方法或代码块即等待获取一个监视器锁。这是与WAITING/TIMED_WAITING的关键区别。WAITING线程处于无限期等待状态等待被其他线程显式唤醒。通常由Object.wait()、Thread.join()或LockSupport.park()导致。TIMED_WAITING线程处于限期等待状态。由Thread.sleep(long)、Object.wait(long)、Thread.join(long)等带超时参数的方法导致。TERMINATED线程已执行完毕。一个常见的误解线程在等待IO如读Socket时在jstack中显示什么状态答案是**RUNNABLE**。因为Java线程状态是JVM层面的它只关心线程是否在等待JVM管理的资源如锁。等待底层操作系统IO操作完成对于JVM来说线程仍然是“可运行”的尽管它可能实际上在操作系统层面被挂起。这一点在分析高IO等待的应用时非常重要不要看到大量RUNNABLE线程就以为是CPU计算繁忙。7. Java内存模型JMM与happens-before这是多线程中最抽象、最难理解但也最核心的部分。它定义了线程如何与内存交互以及什么情况下一个线程对共享变量的写操作对另一个线程可见。7.1 为什么需要JMM现代计算机为了性能会有多级缓存CPU L1/L2/L3 Cache这会导致一个核心修改了数据另一个核心可能无法立即看到即可见性问题。此外编译器和处理器会对指令进行重排序以优化性能这可能导致程序执行顺序与代码书写顺序不一致即有序性问题。JMM就是为了在复杂的硬件和编译器优化背景下给程序员提供一个一致的内存可见性保证。7.2happens-before规则JMM通过happens-before规则来阐述内存可见性。如果操作Ahappens-before操作B那么A所做的任何内存修改对B都是可见的。这是一组偏序关系不需要实际的时间先后。几条关键的happens-before规则程序顺序规则在同一个线程中按照代码顺序前面的操作happens-before后面的操作。注意这仅保证单线程内的语义不影响重排序对多线程的可见性。监视器锁规则对一个锁的解锁操作happens-before于后续对这个锁的加锁操作。volatile变量规则对一个volatile变量的写操作happens-before于后续对这个变量的读操作。传递性如果Ahappens-beforeB且Bhappens-beforeC那么Ahappens-beforeC。一个综合例子// 线程A sharedVariable 1; // 普通写 lock.unlock(); // 操作1解锁 // 线程B lock.lock(); // 操作2加锁 int r sharedVariable; // 操作3读根据规则2操作1happens-before操作2。 根据规则1在单线程B内操作2happens-before操作3。 根据规则4传递性操作1happens-before操作3。 因此线程A在解锁前对sharedVariable的写入对线程B在加锁后的读取是可见的。这就是synchronized能保证可见性的底层原理之一。理解JMM和happens-before你就能从原理上明白为什么synchronized、volatile、final等关键字能保证线程安全而不仅仅是记住结论。当你在代码中正确地使用了这些同步机制时JMM会确保你的程序获得预期的内存可见性。