
理解并发中断问题
在多线程环境中,当多个线程尝试同时访问和修改共享资源时,如果没有适当的同步机制,就可能导致数据不一致、操作混乱或结果不可预测。例如,一个线程正在执行一个多步的打印任务,如果其他线程在其中间插入自己的打印内容,最终的输出将是支离破碎且难以理解的。
面对这类问题,开发者可能会首先想到通过设置线程优先级来解决。然而,线程优先级在Java中是一个高度依赖操作系统调度的提示,它并不能保证线程的执行顺序或防止中断。高优先级的线程可能会获得更多的CPU时间片,但它不能阻止低优先级线程在关键代码段中执行,也不能确保一个操作的原子性。因此,对于需要互斥访问共享资源以完成原子性操作的场景,线程优先级并非一个可靠的解决方案。
核心解决方案:使用synchronized锁
Java提供了强大的内置同步机制来解决并发访问问题,其中最基础和常用的是synchronized关键字。synchronized可以用于修饰方法或代码块,它能够确保在任何时刻,只有一个线程可以执行被synchronized保护的代码段。这有效地创建了一个“临界区”,任何进入该临界区的线程都必须先获得一个锁,当线程退出临界区时,锁被释放,其他等待的线程才有机会获取锁并进入。
对于需要保护共享资源(如打印输出)的场景,我们通常会定义一个共享的锁对象,然后使用synchronized块来包裹对该资源的操作。
实现细节与示例代码
为了确保打印过程不被其他线程中断,我们可以定义一个静态的、最终的Object实例作为锁。所有需要进行互斥打印操作的线程都必须先获取这个锁,才能执行打印逻辑。
立即学习“Java免费学习笔记(深入)”;
以下是一个使用synchronized锁来控制并发打印的示例:
public class ConcurrentPrinter {
// 定义一个静态的、最终的锁对象,确保所有线程共享同一个锁
// 使用一个独立的Object实例作为锁对象是最佳实践,
// 避免锁定this或Class对象可能引入的意外副作用。
private static final Object printLock = new Object();
/**
* 模拟打印文档的方法,通过synchronized块确保打印过程的原子性。
*
* @param documentName 要打印的文档名称
* @param pages 文档的页数
*/
public void printDocument(String documentName, int pages) {
// 使用synchronized(printLock)块来保护打印逻辑
// 任何时刻,只有一个线程能持有printLock并执行此代码块
synchronized (printLock) {
System.out.println("--- 开始打印文档: " + documentName + " ---");
for (int i = 1; i <= pages; i++) {
System.out.println("正在打印 " + documentName + " 的第 " + i + " 页...");
try {
// 模拟打印耗时,确保其他线程有机会竞争锁
Thread.sleep(50);
} catch (InterruptedException e) {
// 捕获中断异常,并重新设置中断标志
Thread.currentThread().interrupt();
System.out.println("打印被中断,文档 " + documentName + " 未完成。");
return; // 打印中断,退出方法
}
}
System.out.println("--- 文档 " + documentName + " 打印完成 ---");
} // synchronized块结束,锁被释放
}
public static void main(String[] args) {
ConcurrentPrinter printer = new ConcurrentPrinter();
// 启动多个线程模拟并发打印,观察输出是否会交错
new Thread(() -> printer.printDocument("报告A", 3), "打印线程-A").start();
new Thread(() -> printer.printDocument("合同B", 2), "打印线程-B").start();
new Thread(() -> printer.printDocument("发票C", 4), "打印线程-C").start();
}
}在上述代码中,printLock是一个所有ConcurrentPrinter实例共享的静态锁对象。当一个线程调用printDocument方法并进入synchronized (printLock)块时,它会尝试获取printLock。如果锁已被其他线程持有,当前线程就会被阻塞,直到锁被释放。一旦当前线程获得锁,它将独占执行synchronized块内的所有代码,完成整个文档的打印过程,然后释放锁。这样就保证了每个文档的打印都是一个原子性操作,不会被其他线程的打印任务所中断。
注意事项与最佳实践
- 锁对象的选择:
- 锁的粒度: 应该只锁定真正需要互斥访问的代码块,而不是整个方法。过度锁定会导致性能下降,因为它限制了并发性。例如,如果一个方法中只有一小部分涉及到共享资源的修改,那么只对这一小部分代码使用synchronized块即可。
- 避免死锁: 当多个线程需要获取多个锁,并且它们以不同的顺序获取这些锁时,可能会发生死锁。虽然synchronized本身不会直接导致死锁,但设计不当的锁获取顺序会导致。在复杂的并发场景中,需要仔细规划锁的获取和释放顺序。
- 异常处理: 在synchronized块内部发生异常时,锁会自动释放。这是synchronized的一个优点,可以避免因异常导致锁无法释放而造成的死锁。
- 替代方案: 对于更复杂的并发控制需求,Java的java.util.concurrent.locks包提供了更灵活的Lock接口(如ReentrantLock),它提供了比synchronized更细粒度的控制,例如尝试非阻塞地获取锁、定时获取锁、公平锁等。然而,对于简单的互斥访问,synchronized通常是足够且更简洁的选择。
总结
当面临多线程环境下对共享资源进行原子性操作的需求时,直接依赖线程优先级是不可靠的。正确的解决方案是利用Java的synchronized关键字配合共享锁对象来保护临界区。通过将需要独占执行的代码放入synchronized块中,可以确保在任何给定时刻只有一个线程能够访问该代码,从而有效地防止并发中断,保证操作的完整性和数据的一致性。理解并正确运用synchronized是Java并发编程中的一项基本而关键的技能。










