Java多线程编程实战：从基础到高级应用

1. 多线程编程的核心价值与挑战十年前我第一次接触多线程编程时被一个简单的计数器程序折磨得彻夜难眠——明明逻辑完全正确运行结果却总是莫名其妙地出错。这就是典型的线程安全问题也是每个多线程开发者必须跨过的第一道坎。多线程技术能让程序像交响乐团一样协同工作但前提是你要当好这个指挥家。现代软件开发中多线程无处不在Web服务器要同时处理成千上万的请求数据处理需要榨干CPU的每一分性能GUI应用要保持界面流畅响应。掌握多线程意味着你能写出更高效、更健壮的程序。但多线程也像一把双刃剑用得好程序飞起用不好bug频出。2. 案例一银行转账的线程安全实现2.1 问题场景还原假设我们有一个银行账户类包含账户余额和转账方法。最直观的实现可能是这样的class BankAccount { private double balance; public void transfer(BankAccount to, double amount) { if (this.balance amount) { this.balance - amount; to.balance amount; } } }这个实现在线程环境下会出大问题。当两个线程同时执行转账操作时可能出现线程A检查余额充足线程B检查余额充足线程A执行扣款线程B执行扣款 导致余额透支或者金额不一致。2.2 解决方案与实现正确的做法是使用synchronized关键字保证操作的原子性class BankAccount { private double balance; private final Object lock new Object(); public void transfer(BankAccount to, double amount) { synchronized(lock) { if (this.balance amount) { this.balance - amount; to.balance amount; } } } }关键点使用专门的锁对象而不是直接锁this可以避免外部代码意外获取锁导致死锁2.3 进阶优化方案更优雅的解决方案是使用java.util.concurrent包中的工具类import java.util.concurrent.locks.ReentrantLock; class BankAccount { private double balance; private final ReentrantLock lock new ReentrantLock(); public void transfer(BankAccount to, double amount) { lock.lock(); try { if (this.balance amount) { this.balance - amount; to.balance amount; } } finally { lock.unlock(); } } }使用ReentrantLock的优势可尝试获取锁(tryLock)可中断的锁获取公平锁选项更好的性能3. 案例二生产者-消费者模式实战3.1 经典模型解析生产者-消费者是多线程协作的经典模式常见于日志处理系统消息队列事件驱动架构基本流程生产者生成数据放入缓冲区消费者从缓冲区取出数据处理当缓冲区满时生产者等待当缓冲区空时消费者等待3.2 Java实现方案使用wait/notifyAll的传统实现class Buffer { private QueueInteger queue new LinkedList(); private int capacity; public Buffer(int capacity) { this.capacity capacity; } public synchronized void produce(int item) throws InterruptedException { while (queue.size() capacity) { wait(); } queue.add(item); notifyAll(); } public synchronized int consume() throws InterruptedException { while (queue.isEmpty()) { wait(); } int item queue.remove(); notifyAll(); return item; } }3.3 使用BlockingQueue简化Java并发包提供了更高级的实现import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; class ProducerConsumer { private BlockingQueueInteger queue new LinkedBlockingQueue(10); public void start() { // 生产者线程 new Thread(() - { try { for (int i 0; i 100; i) { queue.put(i); System.out.println(Produced: i); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); // 消费者线程 new Thread(() - { try { while (true) { Integer item queue.take(); System.out.println(Consumed: item); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); } }BlockingQueue的优势内置线程安全自动阻塞管理多种实现可选有界/无界队列更简洁的代码4. 案例三高性能计数器实现4.1 问题背景统计网站访问量这类高频计数器使用synchronized会导致严重性能问题。测试表明简单synchronized计数器在8核CPU上性能甚至不如单线程4.2 解决方案对比方案一AtomicLongprivate AtomicLong counter new AtomicLong(); public void increment() { counter.incrementAndGet(); }方案二LongAdderJava8private LongAdder counter new LongAdder(); public void increment() { counter.increment(); }性能对比8线程1亿次操作synchronized: 12.8秒AtomicLong: 4.2秒LongAdder: 0.9秒4.3 LongAdder实现原理LongAdder采用了分段计数策略维护一个Cell数组线程哈希到不同Cell上操作最终统计时求和所有Cell值减少CAS竞争开销适用场景高并发写低频读不要求实时精确值5. 案例四线程池任务取消机制5.1 任务取消的挑战当我们需要停止正在执行的任务时直接调用Thread.stop()是危险的已废弃。正确做法是协作式取消任务定期检查取消标志中断机制通过中断信号通知5.2 实现示例ExecutorService executor Executors.newFixedThreadPool(4); Future? future executor.submit(() - { while (!Thread.currentThread().isInterrupted()) { try { // 模拟工作 Thread.sleep(1000); System.out.println(Working...); } catch (InterruptedException e) { // 收到中断信号 Thread.currentThread().interrupt(); System.out.println(Task cancelled); break; } } }); // 5秒后取消任务 Thread.sleep(5000); future.cancel(true); // true表示尝试中断5.3 关键注意事项正确处理InterruptedException要么重新设置中断状态要么直接退出避免不可中断的阻塞操作Socket I/O同步队列操作 解决方案使用可中断的NIO清理资源 在finally块中释放文件句柄、数据库连接等6. 多线程调试与性能优化技巧6.1 调试工具推荐VisualVM监控线程状态、死锁检测jstack获取线程转储IDEA调试器条件断点、线程过滤6.2 常见问题排查死锁现象诊断jstack查看线程阻塞情况查找deadlock关键词分析锁的持有和等待关系CPU占用过高排查top -H找出高CPU线程jstack分析线程堆栈定位热点代码6.3 性能优化原则减小锁粒度分段锁、读写锁降低锁持有时间只锁必要代码避免锁嵌套容易导致死锁考虑无锁数据结构Atomic、ConcurrentHashMap合理设置线程池大小CPU密集型核心数1IO密集型核心数*27. Java并发包最佳实践7.1 ConcurrentHashMap使用技巧复合操作仍需同步// 错误用法 if (!map.containsKey(key)) { map.put(key, value); } // 正确用法 map.computeIfAbsent(key, k - value);遍历时的弱一致性 迭代器反映的是创建时刻的状态7.2 CountDownLatch应用场景典型用例并行任务同步服务启动依赖测试并发场景CountDownLatch latch new CountDownLatch(3); // 工作线程 new Thread(() - { doWork(); latch.countDown(); }).start(); // 主线程等待 latch.await(); System.out.println(All tasks completed);7.3 CompletableFuture异步编程链式调用示例CompletableFuture.supplyAsync(() - fetchData()) .thenApply(data - processData(data)) .thenAccept(result - saveResult(result)) .exceptionally(ex - { System.err.println(Error: ex); return null; });优势避免回调地狱灵活的异常处理组合多个Future8. 现代多线程开发趋势8.1 响应式编程Project Reactor示例Flux.range(1, 10) .parallel() .runOn(Schedulers.parallel()) .map(i - i * 2) .subscribe(System.out::println);特点事件驱动非阻塞IO背压支持8.2 协程与虚拟线程Java19虚拟线程示例try (var executor Executors.newVirtualThreadPerTaskExecutor()) { IntStream.range(0, 10_000).forEach(i - { executor.submit(() - { Thread.sleep(Duration.ofSeconds(1)); return i; }); }); }优势轻量级线程更低的内存开销更高的并发量8.3 多线程设计模式Immutable Object模式无锁线程安全适合配置信息等Thread Local模式线程私有数据避免参数传递Guarded Suspension模式条件不满足时等待条件满足时执行