### Java多线程编程：从基础概念到高级应用

#### 一、多线程基础概念

1. 进程与线程

- 进程：操作系统资源分配的基本单位，拥有独立的内存空间

- 线程：CPU调度的基本单位，共享进程资源，轻量级执行单元

2. Java线程创建方式

```java

// 继承Thread类

class MyThread extends Thread {

@Override

public void run() {

System.out.println(线程执行);

}

}

// 实现Runnable接口

class MyRunnable implements Runnable {

@Override

public void run() {

System.out.println(Runnable线程执行);

}

}

// 实现Callable接口（带返回值）

class MyCallable implements Callable {

@Override

public String call() throws Exception {

return 任务完成;

}

}

```

3. 线程生命周期

- NEW：新建状态

- RUNNABLE：可运行状态

- BLOCKED：阻塞状态

- WAITING：等待状态

- TIMED_WAITING：定时等待

- TERMINATED：终止状态

#### 二、线程同步与通信

1. synchronized关键字

```java

// 同步方法

public synchronized void syncMethod() {

// 线程安全代码

}

// 同步代码块

public void syncBlock() {

synchronized(this) {

// 线程安全代码

}

}

```

2. Lock接口

```java

ReentrantLock lock = new ReentrantLock();

public void lockExample() {

lock.lock();

try {

// 临界区代码

} finally {

lock.unlock();

}

}

```

3. 线程通信机制

```java

// wait/notify机制

class SharedResource {

private boolean available = false;

public synchronized void produce() throws InterruptedException {

while(available) wait();

// 生产操作

available = true;

notifyAll();

}

public synchronized void consume() throws InterruptedException {

while(!available) wait();

// 消费操作

available = false;

notifyAll();

}

}

```

#### 三、Java并发工具类

1. CountDownLatch

```java

CountDownLatch latch = new CountDownLatch(3);

// 多个线程执行完成后继续主线程

latch.await(); // 主线程等待

latch.countDown(); // 工作线程完成

```

2. CyclicBarrier

```java

CyclicBarrier barrier = new CyclicBarrier(3,

() -> System.out.println(所有线程到达屏障));

// 线程到达屏障点等待

barrier.await();

```

3. Semaphore

```java

Semaphore semaphore = new Semaphore(5); // 限制并发数

semaphore.acquire(); // 获取许可

// 访问共享资源

semaphore.release(); // 释放许可

```

#### 四、线程池技术

1. Executor框架

```java

ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务

executor.submit(() -> {

// 任务逻辑

});

executor.shutdown();

```

2. ThreadPoolExecutor

```java

ThreadPoolExecutor executor = new ThreadPoolExecutor(

5, // 核心线程数

10, // 最大线程数

60, // 空闲时间

TimeUnit.SECONDS,

new ArrayBlockingQueue<>(100) // 工作队列

);

```

3. 任务执行结果处理

```java

Future future = executor.submit(new CallableTask());

String result = future.get(); // 阻塞获取结果

// CompletableFuture异步编程

CompletableFuture.supplyAsync(() -> 任务结果)

.thenApply(result -> result + 处理)

.thenAccept(System.out::println);

```

#### 五、高级并发特性

1. 原子操作类

```java

AtomicInteger counter = new AtomicInteger(0);

counter.incrementAndGet(); // 原子自增

AtomicReference reference = new AtomicReference<>(初始值);

```

2. 并发集合

```java

ConcurrentHashMap map = new ConcurrentHashMap<>();

CopyOnWriteArrayList list = new CopyOnWriteArrayList<>();

BlockingQueue queue = new LinkedBlockingQueue<>();

```

3. ThreadLocal

```java

ThreadLocal dateFormat =

ThreadLocal.withInitial(() -> new SimpleDateFormat(yyyy-MM-dd));

// 每个线程独立实例

```

#### 六、性能优化与最佳实践

1. 避免死锁

- 按固定顺序获取锁

- 使用tryLock()设置超时

- 避免嵌套锁

2. 减少锁竞争

- 缩小同步范围

- 使用读写锁（ReentrantReadWriteLock）

- 采用无锁编程（CAS操作）

3. 线程池调优

- 根据任务类型选择合适线程池

- 合理设置线程池参数

- 监控线程池运行状态

#### 七、实际应用场景

1. 高并发Web服务器

- 使用NIO和非阻塞IO

- 线程池处理请求

- 异步Servlet

2. 大数据处理

- 并行计算框架

- Fork/Join框架

- MapReduce模式

3. 实时系统

- 定时任务调度

- 事件驱动架构

- 消息队列处理

#### 八、常见问题与解决方案

1. 内存可见性

- 使用volatile关键字

- 正确使用synchronized

- 遵循happens-before原则

2. 线程安全设计

- 不可变对象

- 线程封闭

- 保护性拷贝

3. 资源管理

- 及时释放锁资源

- 正确处理线程异常

- 优雅关闭线程池

通过系统掌握Java多线程编程的各个层面，开发者能够构建出高性能、高可靠性的并发应用程序。在实际开发中，需要根据具体场景选择合适的并发策略，并持续进行性能测试和优化。