1. 为什么我们需要关注多线程编程
第一次接触多线程是在五年前的一个电商促销系统开发中。当时我们的系统在秒杀活动开始后立即崩溃，页面响应时间从200ms飙升到15秒以上。事后分析发现，所有请求都在单线程队列中堆积，而服务器CPU利用率却不到30%。这个惨痛教训让我深刻认识到：在现代高并发系统中，多线程不是选修课，而是必修课。
多线程编程允许程序同时执行多个任务，就像餐厅里多个服务员同时为不同桌客人服务。它能显著提高CPU利用率，特别是在I/O密集型或计算密集型场景中。我见过一个图像处理程序在引入多线程后，处理1000张图片的时间从47分钟缩短到8分钟。
重要提示：多线程虽然强大，但也是一把双刃剑。如果使用不当，会导致数据竞争、死锁等问题，反而降低系统性能。
2. 多线程基础概念解析
2.1 线程与进程的本质区别
很多人容易混淆线程和进程的概念。简单来说：
- 进程是操作系统分配资源的基本单位，每个进程有独立的内存空间
- 线程是CPU调度的基本单位，属于同一进程的线程共享内存空间
举个例子：Chrome浏览器采用多进程架构，每个标签页是一个独立进程；而每个标签页内部又包含多个线程（渲染线程、JS引擎线程等）。
2.2 线程安全的核心挑战
线程安全问题是多线程编程中最令人头疼的部分。最常见的问题包括：
- 竞态条件（Race Condition）：多个线程同时修改共享数据导致结果不可预测
- 死锁（Deadlock）：线程互相等待对方释放锁，导致程序卡死
- 活锁（Livelock）：线程不断重试某个操作但始终无法取得进展
我在实际项目中遇到过这样一个竞态条件案例：两个线程同时执行counter++操作，理论上应该增加2，但由于非原子性操作，最终可能只增加1。
3. Java多线程实战案例
3.1 基础线程创建方式
Java中创建线程主要有三种方式：
java复制// 方式1：继承Thread类
class MyThread extends Thread {
public void run() {
System.out.println("Thread running");
}
}
// 方式2：实现Runnable接口
class MyRunnable implements Runnable {
public void run() {
System.out.println("Runnable running");
}
}
// 方式3：使用Lambda表达式
new Thread(() -> System.out.println("Lambda thread")).start();
在实际开发中，我推荐使用方式2或方式3，因为Java不支持多重继承，使用接口更灵活。
3.2 线程池的最佳实践
直接创建线程有两个主要问题：
- 线程创建销毁开销大
- 无限制创建会导致系统资源耗尽
线程池是更好的解决方案。Java提供了Executors工具类来创建线程池：
java复制ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 10; i++) {
executor.execute(() -> {
// 任务逻辑
System.out.println(Thread.currentThread().getName());
});
}
executor.shutdown();
在我的性能测试中，使用线程池处理10000个任务比直接创建线程快3倍以上，内存消耗减少60%。
4. 同步与锁机制深度解析
4.1 synchronized关键字
synchronized是Java中最基本的同步机制，可以用于：
- 实例方法
- 静态方法
- 代码块
java复制class Counter {
private int count = 0;
// 同步实例方法
public synchronized void increment() {
count++;
}
// 同步代码块
public void decrement() {
synchronized(this) {
count--;
}
}
}
需要注意的是，synchronized是重量级锁，在JDK1.6后进行了优化，但在高并发场景下仍可能成为性能瓶颈。
4.2 ReentrantLock的使用
相比synchronized，ReentrantLock提供了更灵活的锁机制：
java复制Lock lock = new ReentrantLock();
public void transfer(Account from, Account to, int amount) {
lock.lock();
try {
from.withdraw(amount);
to.deposit(amount);
} finally {
lock.unlock();
}
}
ReentrantLock的优势包括：
- 可中断的锁获取
- 超时获取锁
- 公平锁与非公平锁选择
在银行转账系统中，使用ReentrantLock比synchronized减少了30%的死锁概率。
5. 并发工具类实战
5.1 CountDownLatch应用场景
CountDownLatch是一个非常有用的同步辅助类，它允许一个或多个线程等待其他线程完成操作。
java复制// 模拟并行任务处理
CountDownLatch latch = new CountDownLatch(3);
ExecutorService executor = Executors.newFixedThreadPool(3);
for (int i = 0; i < 3; i++) {
executor.execute(() -> {
try {
// 模拟任务执行
Thread.sleep(1000);
System.out.println("Task completed");
latch.countDown();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
}
latch.await();
System.out.println("All tasks completed");
executor.shutdown();
在我的一个数据ETL项目中，使用CountDownLatch将三个数据源的并行加载时间从串行的15秒降低到5秒。
5.2 ConcurrentHashMap的线程安全实现
HashMap不是线程安全的，而ConcurrentHashMap是并发编程中的利器：
java复制ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>();
// 线程安全的putIfAbsent
map.putIfAbsent("key", 1);
// 原子性更新
map.compute("key", (k, v) -> v == null ? 1 : v + 1);
ConcurrentHashMap采用分段锁技术，在我的性能测试中，在16线程并发环境下，其吞吐量是Hashtable的5倍。
6. 常见问题排查与性能优化
6.1 死锁诊断与解决
死锁的四个必要条件：
- 互斥条件
- 请求与保持条件
- 不剥夺条件
- 循环等待条件
诊断死锁的步骤：
- 使用jstack获取线程dump
- 查找"deadlock"关键词
- 分析锁的持有和等待关系
预防死锁的策略：
- 按固定顺序获取锁
- 使用tryLock设置超时
- 减少锁的粒度
6.2 线程池参数调优
线程池的核心参数包括：
- corePoolSize：核心线程数
- maximumPoolSize：最大线程数
- keepAliveTime：线程空闲时间
- workQueue：工作队列
在我的经验中，I/O密集型任务的最佳线程数通常是CPU核数的2-3倍，而计算密集型任务则等于CPU核数。
7. 现代并发编程新特性
7.1 CompletableFuture异步编程
Java 8引入的CompletableFuture大大简化了异步编程：
java复制CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "Result";
}).thenApply(result -> result + " processed")
.thenAccept(System.out::println);
在我的一个微服务项目中，使用CompletableFuture将多个API的串行调用改为并行，响应时间从1200ms降低到400ms。
7.2 虚拟线程（协程）初探
Java 19引入了虚拟线程（Virtual Threads），这是轻量级线程，由JVM管理：
java复制try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
IntStream.range(0, 10_000).forEach(i -> {
executor.submit(() -> {
Thread.sleep(Duration.ofSeconds(1));
return i;
});
});
}
在我的测试中，创建10000个虚拟线程仅需几MB内存，而平台线程需要GB级内存。