1. Java线程基础概念解析线程作为Java并发编程的核心概念理解其本质是掌握多线程编程的第一步。线程Thread是操作系统能够进行运算调度的最小单位它被包含在进程之中是进程中的实际运作单位。在Java中每个线程都对应一个Thread类的实例。1.1 线程与进程的本质区别线程与进程最根本的区别在于资源分配和执行调度进程是操作系统资源分配的基本单位每个进程都有独立的代码和数据空间线程是CPU任务调度和执行的基本单位同一进程的多个线程共享进程的资源从JVM视角看每个Java程序启动时JVM会创建一个主线程来执行main()方法。我们可以通过Thread.currentThread()获取当前线程的引用public class ThreadDemo { public static void main(String[] args) { Thread mainThread Thread.currentThread(); System.out.println(当前线程 mainThread.getName()); } }1.2 线程的生命周期状态Java线程在其生命周期中会经历多种状态这些状态在Thread.State枚举中明确定义NEW新建线程对象刚创建但尚未调用start()RUNNABLE可运行调用start()后进入此状态包括就绪和运行中两种子状态BLOCKED阻塞线程等待获取监视器锁时的状态WAITING等待调用Object.wait()、Thread.join()等方法后的状态TIMED_WAITING定时等待带有超时参数的等待状态TERMINATED终止线程执行完毕后的状态注意从操作系统层面看RUNNABLE状态实际上包含了Java层面的RUNNABLE就绪和RUNNING运行中两种状态。Java线程状态模型是对底层操作系统线程状态的抽象和简化。2. 线程创建与启动机制2.1 三种创建方式对比Java中创建线程主要有三种方式每种方式各有适用场景继承Thread类class MyThread extends Thread { Override public void run() { System.out.println(继承Thread方式); } } // 使用 new MyThread().start();实现Runnable接口class MyRunnable implements Runnable { Override public void run() { System.out.println(实现Runnable方式); } } // 使用 new Thread(new MyRunnable()).start();实现Callable接口带返回值class MyCallable implements CallableString { Override public String call() throws Exception { return 实现Callable方式; } } // 使用 FutureTaskString task new FutureTask(new MyCallable()); new Thread(task).start(); System.out.println(task.get()); // 获取返回值三种方式对比表格特性继承Thread实现Runnable实现Callable是否支持返回值否否是是否可抛出异常否否是是否可继承其他类否是是资源共享能力差好好适合场景简单任务一般任务需要结果任务2.2 start()与run()方法区别初学者常犯的错误是直接调用run()方法而非start()Thread thread new Thread(() - System.out.println(Running)); thread.run(); // 错误在主线程执行 thread.start(); // 正确启动新线程关键区别start()JVM会创建新线程在新线程中执行run()方法run()只是普通方法调用仍在当前线程执行经验法则永远不要直接调用run()方法这违背了多线程设计的初衷。如果需要同步执行任务应该直接调用方法而不是创建Thread对象。3. 线程同步与锁机制3.1 synchronized关键字原理synchronized是Java内置的同步机制它通过对象监视器Monitor实现同步// 同步代码块 public void syncMethod() { synchronized(this) { // 临界区代码 } } // 同步方法等价于同步代码块 public synchronized void syncMethod() { // 临界区代码 }底层实现原理同步代码块使用monitorenter和monitorexit指令同步方法使用ACC_SYNCHRONIZED方法标志每个对象都有一个关联的Monitor线程通过获取Monitor实现互斥3.2 volatile关键字作用volatile解决的是内存可见性问题确保变量的修改对所有线程立即可见private volatile boolean flag false; public void setFlag() { flag true; // 写操作对其他线程立即可见 }volatile的两大特性可见性写操作会立即刷新到主内存读操作直接从主内存读取禁止指令重排序避免编译器优化导致代码执行顺序改变注意volatile不能保证原子性像i这样的复合操作仍需同步。适合用作状态标志位但不适合计数器场景。3.3 Lock接口与AQS框架Java.util.concurrent.locks包提供了更灵活的锁机制Lock lock new ReentrantLock(); lock.lock(); try { // 临界区代码 } finally { lock.unlock(); // 必须手动释放 }AQSAbstractQueuedSynchronizer核心思想通过CLH队列管理等待线程通过state变量表示锁状态提供tryAcquire/tryRelease等模板方法供子类实现与synchronized对比优势可中断的获取锁lockInterruptibly超时获取锁tryLock(timeout)公平锁与非公平锁可选支持多个条件变量Condition4. 线程池深度解析4.1 线程池核心参数ThreadPoolExecutor的构造函数包含以下核心参数public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueRunnable workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)参数说明表格参数名说明corePoolSize核心线程数即使空闲也不会被回收maximumPoolSize最大线程数当workQueue满时才会创建新线程直到达到此值keepAliveTime非核心线程空闲存活时间unit时间单位workQueue任务队列常用LinkedBlockingQueue、ArrayBlockingQueue、SynchronousQueuethreadFactory线程工厂用于自定义线程创建过程handler拒绝策略当线程池和队列都满时的处理方式4.2 四种拒绝策略对比当线程池无法处理新任务时会触发拒绝策略AbortPolicy默认抛出RejectedExecutionExceptionCallerRunsPolicy由提交任务的线程直接执行该任务DiscardPolicy静默丢弃被拒绝的任务DiscardOldestPolicy丢弃队列中最老的任务然后重试提交自定义拒绝策略示例new RejectedExecutionHandler() { Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { // 记录日志或持久化任务 logger.warn(Task rejected: r.toString()); } }4.3 线程池工作流程线程池处理任务的标准流程提交任务后如果当前线程数 corePoolSize创建新线程执行如果线程数 corePoolSize将任务放入workQueue如果队列已满且线程数 maximumPoolSize创建新线程执行如果队列和线程数都达到上限触发拒绝策略流程图表示提交任务 → 核心线程是否满 → 否 → 创建核心线程执行 ↓是 队列是否满 → 否 → 加入队列等待 ↓是 线程数是否达到最大值 → 否 → 创建临时线程执行 ↓是 执行拒绝策略5. 线程安全实践与性能优化5.1 常见线程安全问题竞态条件多个线程同时修改共享数据// 不安全的计数器 class Counter { private int count; public void increment() { count; } }内存可见性问题线程读取到过期的数据class VisibilityProblem { boolean ready false; // 一个线程设置readytrue另一个线程可能永远看不到 }死锁多个线程互相等待对方释放锁// 典型死锁示例 Thread 1: 获取锁A尝试获取锁B Thread 2: 获取锁B尝试获取锁A5.2 并发工具类应用Java并发包提供了多种线程安全容器ConcurrentHashMap分段锁实现的线程安全HashMapMapString, String map new ConcurrentHashMap();CopyOnWriteArrayList写时复制的线程安全ListListString list new CopyOnWriteArrayList();CountDownLatch倒计时门闩等待多个线程完成CountDownLatch latch new CountDownLatch(3); // 工作线程完成后调用latch.countDown() latch.await(); // 等待所有线程完成CyclicBarrier循环屏障线程互相等待CyclicBarrier barrier new CyclicBarrier(3, () - System.out.println(所有线程到达屏障));5.3 性能优化建议减少锁粒度缩小同步代码块范围// 不好 public synchronized void bigMethod() { /*...*/ } // 更好 public void method() { synchronized(this) { // 最小临界区 } }使用读写锁读多写少场景使用ReentrantReadWriteLockReadWriteLock rwLock new ReentrantReadWriteLock(); rwLock.readLock().lock(); // 多个读线程可同时获取 rwLock.writeLock().lock(); // 写锁独占避免锁嵌套容易导致死锁// 危险代码 synchronized(lockA) { synchronized(lockB) { /*...*/ } }使用线程局部变量ThreadLocal避免共享private static ThreadLocalSimpleDateFormat dateFormat ThreadLocal.withInitial(() - new SimpleDateFormat(yyyy-MM-dd));6. Java内存模型与happens-before6.1 JMM核心概念Java内存模型(JMM)定义了线程如何与内存交互主要解决以下问题原子性哪些操作是不可分割的可见性一个线程的修改何时对其他线程可见有序性指令重排序的规则限制JMM中的内存划分主内存所有共享变量存储的位置工作内存每个线程私有的内存空间保存用到的主内存副本6.2 happens-before规则happens-before关系确保前一个操作的结果对后续操作可见程序顺序规则同一线程中的操作按程序顺序执行锁规则解锁操作happens-before后续的加锁操作volatile规则volatile写happens-before后续的读线程启动规则Thread.start() happens-before新线程中的操作线程终止规则线程中的所有操作happens-before其他线程检测到它终止中断规则调用interrupt() happens-before检测到中断终结器规则对象构造函数happens-before它的finalize()传递性A happens-before BB happens-before C则A happens-before C7. 常见问题排查与调试7.1 死锁检测与解决死锁产生的四个必要条件互斥条件请求与保持不可剥夺循环等待诊断死锁方法使用jstack获取线程转储jstack pid thread_dump.txt查找deadlock关键词分析锁的持有和等待关系避免死锁策略按固定顺序获取锁使用tryLock()带超时减少锁的持有时间使用更高级的并发工具7.2 线程泄漏排查线程泄漏常见症状线程数持续增长不释放应用性能逐渐下降最终抛出OutOfMemoryError排查步骤使用jvisualvm或jconsole监控线程数定期获取线程转储分析检查线程池配置是否正确确保任务不会无限阻塞7.3 性能问题诊断常见多线程性能问题锁竞争激烈contention上下文切换过多缓存失效false sharing不合理的线程池配置优化工具JProfiler分析锁竞争和线程状态YourKit检测热点同步块Java Flight Recorder低开销的性能监控8. Java并发编程最佳实践8.1 设计原则优先使用不可变对象避免同步需求public final class ImmutableValue { private final int value; public ImmutableValue(int value) { this.value value; } public int getValue() { return value; } }封装线程安全将同步逻辑封装在类内部public class Counter { private long value; public synchronized long get() { return value; } public synchronized long increment() { return value; } }文档化线程安全保证明确说明类的线程安全级别不可变Immutable线程安全Thread-safe条件线程安全Conditionally thread-safe非线程安全Not thread-safe8.2 工具类选择指南并发工具选择矩阵需求场景推荐工具类简单的互斥访问synchronized或ReentrantLock读多写少的共享数据ReentrantReadWriteLock线程集合点CountDownLatch/CyclicBarrier延迟初始化AtomicReferencecompareAndSet任务分解与结果合并ForkJoinPool定时任务调度ScheduledThreadPoolExecutor生产者-消费者模式BlockingQueue8.3 调试技巧给线程命名方便问题定位Executors.newFixedThreadPool(4, r - { Thread t new Thread(r); t.setName(Worker- t.getId()); return t; });使用ThreadLocal存储上下文private static ThreadLocalRequestContext context new ThreadLocal();记录未捕获异常Thread.setDefaultUncaughtExceptionHandler((t, e) - { logger.error(Uncaught exception in thread t.getName(), e); });使用断言验证不变条件synchronized(lock) { assert Thread.holdsLock(lock); // 临界区代码 }9. Java新版本并发特性9.1 Java 8的并发增强CompletableFuture更强大的异步编程CompletableFuture.supplyAsync(() - fetchData()) .thenApply(data - process(data)) .thenAccept(result - save(result));StampedLock乐观读锁StampedLock lock new StampedLock(); long stamp lock.tryOptimisticRead(); if (!lock.validate(stamp)) { stamp lock.readLock(); // 回退到悲观读 }并行流list.parallelStream() .filter(item - item.isValid()) .forEach(System.out::println);9.2 Java 9的改进反应式流APIjava.util.concurrent.FlowVarHandle替代Unsafe的部分功能虚拟线程协程Java 19预览特性10. 生产环境实战经验10.1 线程池配置经验根据工作负载类型配置线程池CPU密集型任务核心线程数 CPU核心数 1使用有界队列防止内存溢出示例图像处理、复杂计算IO密集型任务核心线程数可设置较大如2*CPU核心数使用较大的队列或SynchronousQueue示例网络请求、数据库操作动态调整线程池参数ThreadPoolExecutor executor (ThreadPoolExecutor) Executors.newCachedThreadPool(); executor.setCorePoolSize(newSize); executor.prestartAllCoreThreads(); // 立即生效10.2 性能监控指标关键监控指标线程池活跃线程数任务队列大小任务完成数/拒绝数平均任务执行时间锁竞争情况Spring Boot Actuator集成management.endpoints.web.exposure.includemetrics,threaddump management.endpoint.metrics.enabledtrue management.endpoint.threaddump.enabledtrue10.3 常见陷阱规避避免在锁内调用外部方法synchronized(lock) { externalService.call(); // 危险可能阻塞或死锁 }正确处理InterruptedExceptiontry { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); // 恢复中断状态 // 清理资源并退出 }避免过度同步// 不好 public synchronized ListString getItems() { return new ArrayList(items); // 复制操作不需要同步 } // 更好 public ListString getItems() { synchronized(this) { return new ArrayList(items); } }注意线程安全的单例模式// 双重检查锁定模式 class Singleton { private static volatile Singleton instance; public static Singleton getInstance() { if (instance null) { synchronized(Singleton.class) { if (instance null) { instance new Singleton(); } } } return instance; } }通过深入理解Java线程的各个方面开发者可以构建出既正确又高效的并发程序。记住并发编程的首要目标是正确性其次才是性能优化。在实际开发中应该优先使用高级并发工具如并发集合、线程池等而不是从零开始构建同步机制。