第五章 多线程与并发编程
第三节 线程同步与通信
概述
在现代软件开发中，多线程技术是实现高效并发处理的关键手段。然而，多线程环境下的共享资源竞争会引发数据不一致和程序错误，线程同步与通信成为确保多线程程序正确性的基础。本节将详细介绍线程同步和线程通信的核心概念、原理及实现方法，帮助考生系统理解并掌握多线程并发编程的关键技术。通过理论解析与典型实例，深入探讨线程间如何协调操作共享资源及有效交换信息，确保程序的安全性和稳定性。
学习目标：
- 理解线程同步的必要性及实现机制
- 掌握常用同步工具（如锁、信号量、条件变量等）
- 理解线程通信的原理与实现方式
- 通过实例掌握同步与通信的应用场景与注意事项
核心概念
线程同步
线程同步是指多个线程在访问共享资源时，通过某种机制协调它们的执行顺序，避免数据冲突和不一致问题。同步保证同一时间只有一个线程访问临界区，防止竞态条件（Race Condition）。
线程通信
线程通信是指线程之间交换信息的过程，使得线程可以协同完成任务。线程通信通常用于生产者-消费者模型、任务调度等场景，实现线程间的协作。
竞态条件（Race Condition）
多个线程同时访问并修改共享资源，操作顺序不确定，导致程序状态不可预测的错误。
临界区（Critical Section）
访问共享资源的那段代码区间，必须保证同一时刻只有一个线程执行。
互斥锁（Mutex）
一种同步机制，用来保护临界区，防止多个线程同时访问共享资源。
信号量（Semaphore）
一种计数同步工具，控制多个线程对有限资源的访问数量。
条件变量（Condition Variable）
一种线程等待和通知机制，线程可以等待某个条件成立，其他线程通知其继续执行。
原理分析
线程同步的工作原理
同步机制通过锁定共享资源的访问，保证线程在进入临界区前必须获得相应的同步工具（如锁），线程完成操作后释放锁，其他线程才能继续访问。这个过程阻止了并发访问带来的数据竞争和不一致问题。
互斥锁是最常用的同步工具，内部通过操作系统调度实现线程阻塞和唤醒，保证只有一个线程拥有锁。信号量则通过维护一个计数器，实现对多个资源的控制，条件变量则允许线程在某个条件不满足时等待，条件满足时被唤醒。
线程通信的工作原理
线程通信通常借助共享变量配合同步机制完成。例如，生产者线程生产数据后修改共享缓冲区状态，并通过条件变量通知等待的消费者线程，消费者接收到通知后开始消费数据。通信的关键是保证信息状态的一致性和及时传递，避免死锁和资源浪费。
详细内容
1. 线程同步基础
多线程程序中，如果多个线程同时访问共享资源，可能导致数据错误。为避免这种情况，需要使用同步机制。同步的本质是协调线程执行，使得对共享资源的访问成为原子操作。
- 互斥锁（Mutex）：最基本的同步工具。线程进入临界区前调用锁操作，退出后释放锁。只有获得锁的线程才能执行临界区代码。
- 递归锁（Reentrant Lock）：允许同一个线程多次获得同一把锁，避免死锁。
- 读写锁（ReadWrite Lock）：区分读和写操作，多线程可同时读，但写操作互斥。
示例：
synchronized(lock) {
// 临界区代码
}
或使用显式锁：
lock.lock();
try {
// 临界区
} finally {
lock.unlock();
}
2. 信号量（Semaphore）
信号量是一个计数器，表示当前可用资源数量。线程请求资源时，信号量减一；释放资源时，信号量加一。如果信号量为0，线程阻塞等待。
- 二进制信号量：类似互斥锁，只允许一个线程访问
- 计数信号量：允许多个线程同时访问有限资源
信号量常用于限流、资源池管理等场景。
3. 条件变量与线程通信
仅有锁不能实现线程间的信息交换，条件变量提供了线程等待和通知机制。
- wait()：线程释放锁并进入等待状态，等待条件满足
- notify()/notifyAll()：唤醒等待线程，使其重新获得锁并继续执行
条件变量用于实现生产者-消费者模式、事件等待等。
4. 线程通信的实现模式
- 生产者-消费者模型：生产者生成数据放入缓冲区，消费者取出数据。缓冲区为空时消费者等待，缓冲区满时生产者等待。
- 信号传递：线程间通过共享变量和条件变量传递状态信息。
5. 死锁与同步陷阱
死锁是多线程同步中常见问题，因多个线程相互等待对方释放资源，导致程序无法继续。
死锁四个必要条件：
- 互斥条件
- 占有且等待
- 不可剥夺
- 环路等待
避免死锁的方法包括锁顺序控制、超时锁、避免占有且等待等。
实例分析
案例一：使用互斥锁解决账户余额更新的竞态条件
背景：多个线程同时操作银行账户余额，导致余额错误。
分析：线程在读取余额后进行计算，若不加锁，多个线程可能同时读取相同余额，导致更新错误。
实现：使用互斥锁保护余额的更新操作，确保同一时刻只有一个线程修改数据。
class Account {
private int balance = 1000;
private final Object lock = new Object();
public void withdraw(int amount) {
synchronized(lock) {
if (balance >= amount) {
balance -= amount;
}
}
}
}
结论：锁机制保证了余额更新的原子性，避免了数据竞争。
案例二：生产者-消费者模型实现线程通信
背景：生产者线程生成数据，消费者线程消费，使用共享缓冲区。
分析：需要同步访问缓冲区并实现线程通信，避免缓冲区溢出或空耗。
实现：使用条件变量wait()和notify()实现线程等待与唤醒。
class Buffer {
private Queue<Integer> queue = new LinkedList<>();
private final int capacity = 5;
public synchronized void produce(int value) throws InterruptedException {
while (queue.size() == capacity) {
wait();
}
queue.add(value);
notifyAll();
}
public synchronized int consume() throws InterruptedException {
while (queue.isEmpty()) {
wait();
}
int val = queue.remove();
notifyAll();
return val;
}
}
结论：线程通过wait和notify实现协调，保证数据生产和消费的有序进行。
案例三：使用信号量控制资源访问数量
背景：多个线程访问有限资源，如数据库连接池。
分析：通过信号量控制同时访问的线程数量，避免资源超载。
实现：使用计数信号量管理资源分配。
Semaphore semaphore = new Semaphore(3); // 最多3个线程
public void accessResource() {
try {
semaphore.acquire();
// 访问资源
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
semaphore.release();
}
}
结论：信号量有效管理资源并发访问，防止过载。
常见误区
忽视锁释放导致死锁
- 线程获得锁后未及时释放，其他线程永久等待。
- 正确做法：使用try-finally结构确保锁释放。
使用锁过度或不足
- 过度加锁导致性能下降，锁不足导致数据竞争。
- 正确做法：仅保护必要临界区，减小锁粒度。
错误使用wait/notify
- 在未持有锁的情况下调用wait或notify抛异常。
- 正确做法：调用wait/notify必须在同步代码块内部。
忽视死锁产生条件
- 多线程申请锁顺序不一致，导致死锁。
- 正确做法：统一锁顺序，避免循环等待。
共享变量未加同步直接访问
- 线程间直接访问共享变量导致数据不一致。
- 正确做法：使用同步机制保护共享变量。
应用场景
- 服务器并发处理：多线程处理客户端请求时，使用同步保证共享数据正确。
- 生产者-消费者模型：数据采集与处理分离，通过线程通信协调。
- 资源池管理：数据库连接池、线程池控制并发访问数量。
- 任务调度：线程间协调任务执行顺序，保证数据依赖。
- 实时系统：多线程协作完成复杂计算和数据交换。
知识拓展
- 锁优化技术：自旋锁、读写锁、偏向锁等，提高性能。
- 非阻塞同步：使用原子变量（如AtomicInteger）实现无锁编程。
- 并发容器：Java并发包中的并发集合实现线程安全。
- 线程池与任务调度框架：Executor框架实现高效线程管理。
- 内存模型与可见性：深入理解Java内存模型，保证同步可见性。
总结回顾
本节系统介绍了线程同步与通信的核心内容，包括同步机制的定义、工作原理及实现方法。重点讲解了互斥锁、信号量、条件变量三大同步工具，以及生产者-消费者模型这一经典线程通信模式。通过典型案例，展示了多线程访问共享资源时如何保证数据安全和线程协作的有效方式。
同时，指出多线程同步编程中的常见误区与避免方法，帮助考生理解同步陷阱及死锁问题。结合实际应用场景，强调同步与通信技术在并发程序设计中的重要性。
掌握本节内容，能够有效编写健壮的多线程程序，为通过全国计算机等级考试四级面向对象程序设计科目打下坚实基础。