线程同步与通信——Java多线程核心技术详解
概述
在现代软件开发中，多线程技术被广泛应用于提升程序的并发处理能力和响应速度。Java语言作为主流编程语言，提供了丰富的多线程支持机制。本节重点讲解多线程中的线程同步与线程通信两个核心内容。通过学习本节，考生将掌握线程同步的必要性、实现方法及其底层原理，同时深入了解线程间通信的机制与应用，从而能够编写安全、高效的多线程程序。
学习目标如下：
- 理解线程同步的概念及其重要性
- 掌握Java中实现同步的关键字与机制
- 理解线程通信的原理及常用方法
- 掌握wait()、notify()、notifyAll()的使用规范
- 能够结合实例分析多线程同步与通信的应用
核心概念
线程同步（Thread Synchronization）
线程同步是指在多线程环境下，控制多个线程对共享资源的访问顺序，避免出现数据不一致或竞争条件的问题。同步保证同一时刻只有一个线程访问共享资源，从而保持数据的完整性和正确性。
线程通信（Thread Communication）
线程通信是指多个线程之间通过共享对象的监视器（锁）进行协调，互相通知状态的变化，实现协作工作。通信机制主要依赖于对象的等待队列和通知机制。
关键字与概念
- synchronized：Java中实现同步的基本关键字，保证代码块或方法的原子性执行。
- 锁（Lock）：控制线程访问资源的机制，Java内置锁即对象锁。
- wait()：使当前线程释放锁并进入等待状态，直到被其他线程通知。
- notify()：唤醒一个等待线程。
- notifyAll()：唤醒所有等待线程。
原理分析
线程同步的原理
多线程同时访问共享变量时，如果没有同步机制，就可能发生数据竞争和不一致。Java使用**对象监视器锁（monitor）**机制实现同步。每个对象都有一个监视器，线程在执行synchronized修饰的同步代码时，必须先获得对象的监视器锁，锁定后其他线程无法进入该同步代码块，直到锁被释放。
锁的获取与释放过程：
- 线程尝试获取对象的监视器锁
- 成功获取后，进入同步代码块
- 执行完毕，释放监视器锁
这保证了同一时刻只有一个线程操作共享资源，防止数据破坏。
线程通信的原理
线程通信依赖于等待/通知机制，所有对象都具有等待队列和通知机制。线程可以调用对象的wait()方法进入等待状态，自动释放锁，直到被其他线程调用notify()/notifyAll()方法唤醒。唤醒后线程重新争夺锁，获得锁后继续执行。
此机制允许线程间协作，例如生产者-消费者模型中，生产者等待缓冲区空位，消费者等待缓冲区有数据，通过wait()和notify()实现同步。
详细内容
1. 线程同步的必要性
多线程环境下，如果多个线程同时修改共享变量，会导致数据不一致。例如两个线程同时给一个变量加1，如果没有同步，最终结果可能小于预期。同步可以避免这种问题。
示例场景：银行账户余额更新、库存数量管理、计数器累加等。
2. synchronized关键字详解
synchronized是Java实现同步的核心关键字。它可以修饰方法和代码块。
- 修饰实例方法：同步当前对象的监视器锁。
- 修饰静态方法：同步当前类的Class对象锁。
- 修饰代码块：指定同步锁对象，提高灵活性。
示例代码：
public class Counter {
private int count = 0;
public synchronized void increment() {
count++;
}
public int getCount() {
return count;
}
}
此处increment()方法为同步方法，防止多个线程同时修改count。
3. 同步代码块的使用
同步代码块可以指定任意对象作为锁，适合细粒度控制。
public class Counter {
private int count = 0;
private final Object lock = new Object();
public void increment() {
synchronized(lock) {
count++;
}
}
public int getCount() {
return count;
}
}
此方式避免了方法整体同步，提高效率。
4. 线程通信机制详解
线程通信主要用于线程间协作，典型场景是生产者-消费者问题。
- wait()：调用后线程进入等待状态并释放锁，等待通知唤醒。
- notify()：唤醒一个等待线程。
- notifyAll()：唤醒所有等待线程。
重要规则：这三个方法必须在同步代码块或同步方法中调用，否则会抛出IllegalMonitorStateException。
5. wait/notify实现线程通信
示例：
class Drop {
private String message;
private boolean empty = true;
public synchronized String take() {
while (empty) {
try {
wait();
} catch (InterruptedException e) {}
}
empty = true;
notifyAll();
return message;
}
public synchronized void put(String message) {
while (!empty) {
try {
wait();
} catch (InterruptedException e) {}
}
empty = false;
this.message = message;
notifyAll();
}
}
生产者调用put()，消费者调用take()，通过wait/notifyAll实现交替执行。
6. Condition接口简介
Java 5以后引入了java.util.concurrent.locks.Condition接口，提供比wait/notify更灵活的线程通信方式。Condition允许多组等待队列，避免notifyAll唤醒所有线程的性能开销。
使用示例：
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();
lock.lock();
try {
while (condition不满足) {
condition.await();
}
// 执行任务
condition.signal();
} finally {
lock.unlock();
}
实例分析
实例一：银行账户的线程同步
背景：多个线程同时操作一个银行账户的余额，执行存款和取款操作。
分析：如果不加同步，可能出现余额计算错误，导致账号透支或余额不正确。
代码示例：
class Account {
private int balance = 1000;
public synchronized void deposit(int amount) {
balance += amount;
}
public synchronized void withdraw(int amount) {
if (balance >= amount) {
balance -= amount;
}
}
public int getBalance() {
return balance;
}
}
结论：使用synchronized保证了余额操作的原子性和数据安全。
实例二：生产者-消费者模型
背景：一个生产者线程生产数据，消费者线程消费数据，使用共享缓冲区。
分析：使用wait和notifyAll进行线程通信，实现交替生产和消费。
代码示例：
class Buffer {
private int data;
private boolean available = false;
public synchronized void put(int value) throws InterruptedException {
while (available) wait();
data = value;
available = true;
notifyAll();
}
public synchronized int get() throws InterruptedException {
while (!available) wait();
available = false;
notifyAll();
return data;
}
}
结论：通过wait和notifyAll实现了线程间有效通信，避免了数据冲突。
实例三：使用Condition优化生产者-消费者
背景：改用Lock和Condition接口，提升灵活性和性能。
代码示例：
class Buffer {
private int data;
private boolean available = false;
private final Lock lock = new ReentrantLock();
private final Condition condition = lock.newCondition();
public void put(int value) throws InterruptedException {
lock.lock();
try {
while (available) condition.await();
data = value;
available = true;
condition.signalAll();
} finally {
lock.unlock();
}
}
public int get() throws InterruptedException {
lock.lock();
try {
while (!available) condition.await();
available = false;
condition.signalAll();
return data;
} finally {
lock.unlock();
}
}
}
结论：Condition实现了更细粒度的等待通知机制，避免notifyAll带来的性能浪费。
常见误区
在非同步代码块中调用wait/notify
- 错误：调用wait()或notify()时未获取对象锁，导致程序抛出IllegalMonitorStateException。
- 正确：必须在synchronized代码块或同步方法中调用。
使用notify代替notifyAll可能导致线程死锁
- notify只唤醒一个线程，若唤醒的线程无法继续执行，可能导致所有线程等待。
- 建议在大多数情况下使用notifyAll。
忽略wait()方法可能被虚假唤醒
- wait()线程被唤醒后应重新检查条件，建议使用while循环判断条件。
滥用同步导致性能瓶颈
- 过大范围同步代码块会降低并发性。
- 应细化同步范围，避免不必要的锁竞争。
未正确处理InterruptedException
- wait()和await()可能抛出InterruptedException，必须捕获或抛出。
应用场景
- 多线程数据共享与保护：银行账户、计数器、缓存数据等共享资源操作。
- 生产者-消费者模式：消息队列、任务调度、缓冲区管理。
- 线程间任务协作：例如多线程下载时等待资源准备完成。
- 异步事件处理：线程等待某事件完成后继续执行。
- 高性能并发编程：使用Condition接口实现复杂的线程通信逻辑。
知识拓展
- 锁升级机制：Java虚拟机对synchronized锁进行优化，如偏向锁、轻量级锁和重量级锁。
- Lock接口及其实现：ReentrantLock等提供更灵活的锁机制。
- 线程安全的集合类：如ConcurrentHashMap、BlockingQueue等内置同步机制。
- 死锁问题及预防：理解死锁产生条件及如何避免。
- 线程池与并发框架：Executor框架结合同步通信提高程序设计效率。
总结回顾
本节详细介绍了Java多线程中的核心技术——线程同步与线程通信。同步通过synchronized关键字和锁机制，确保多线程访问共享资源时数据的正确性和一致性。通信机制基于对象监视器的wait/notify方法，实现线程间的有效协作。深入理解这些机制，掌握正确使用方式，对于编写健壮、高效的多线程程序至关重要。
考生应重点掌握：
- synchronized的使用场景和注意事项
- wait()与notify()/notifyAll()的调用规范与协作流程
- 生产者-消费者模型的同步通信实现
- 避免常见错误，如非法调用、虚假唤醒、死锁等
通过理论结合实例的学习，可以更好地理解多线程同步与通信的本质，为全国计算机等级考试二级Java语言程序设计的相关内容打下坚实基础。