随着硬件技术的快速发展(比如多核处理器,超线程技术),我们通常会在代码中使用多线程(比如线程池)来提高性能,但是,多线程又会带来线程安全问题。因此,本文将深入探讨Java中的线程安全问题。
首先,我们来看看维基百科对线程安全是如何描述的,如下图:
总结一下:线程安全(Thread Safety)是指多个线程访问共享资源时,不会破坏资源的完整性。如下图:
请注意,导致线程安全问题一定要同时具备以下 3个条件,缺一不可:
上面从表象上说明线程安全需要具备的 3个条件,在 Java中,线程安全性通常涉及以下 3个指标:
在 Java中,造成线程安全问题的根因是硬件结构,为了消除 CPU和主内存之间的硬件速度差,通常会在两者之间设置多级缓存(L1 ~ L3),如下图:
Java为了适配这种多级缓存的硬件构造,设计了一套与之对应的内存模型(JMM,Java memory model,包括主内存和工作内存,如下图:
线程对变量的所有操作(读取、写入)都必须在工作内存中进行,而不能直接读写主内存中的变量。线程之间无法直接访问对方的工作内存,变量的传递需要通过主内存来完成。
关于 Java内存模型的原理,我们会在另外的文章中单独讲解,本文只是概要性的总结。
在数据库事务ACID中也有原子性(Atomicity)的概念,它是指一个操作是不可分割的,即要么全部执行,要么全部不执行。Java线程安全中的原子性与数据库事务中的原子性本质是一样的,只是它们应用的上下文和具体实现有所不同。
Java提供了多种方式来保证原子性,比如 同步块、锁或者原子类。
为了更好的说明原子性,我们这里以一个反例来展示不具备原子性,如下代码:
public class AtomicityTest { private int i = 0; public void increment() { i++; }}
在上述代码中,i++这种写法在我们的日常开发经常使用,但它不是一个原子操作,实际上i++分为三步:
如果多个线程同时执行increment()方法,可能会导致i的值不正确,比如有 3个线程A,B,C:
3个线程都对i进行i++操作,预期i的最终值是 3,但因为i++无法保证原子性,因此,i最终的值未达到预期的值。
可见性是指一个线程对共享变量的修改,其他线程能立刻看到。在Java中,volatile关键字可以保证变量的可见性。
为了更好的说明可见性,我们这里以一个示例进行分析,如下代码:
public class VisibilityTest { private boolean running = true; public void stop() { running = false; } public void run() { while (running) { // do something } }}
在上述代码中,变量running是一个全局变量,如果没有使用volatile关键字,running 变量的修改可能不会被其他线程立即看到。
有序性是指程序代码的执行顺序。在单线程环境中,代码的执行顺序通常是按照代码的书写顺序执行的。然而,在多线程环境中,编译器、JVM和CPU可能会为了优化性能进行指令重排序(Instruction Reordering),这可能会导致代码的执行顺序与预期不一致。
Java内存模型(Java Memory Model, JMM)允许编译器和处理器进行指令重排序,但会保证单线程内的执行结果和多线程内的同步结果是正确的。
这里以一个反例来展示不具备有序性,如下代码:
public class ReorderingExample {private int x = 0;private boolean flag = false; public void writer() { x = 42; flag = true; } public void read() { if (flag) { System.out.println(x); // 可能输出0 } }}
在上述代码中,read()方法可能会看到flag=true,但x仍然为 0,因为编译器或CPU可能对指令进行重排序。
在 Java中,通常可以通过以下几个方式来保证线程安全。
(1) synchronized关键字
synchronized是Java的一个原语关键字,它可以保证方法或代码块在同一时刻只能被一个线程执行,从而确保原子性和可见性。
下面的代码是synchronized关键字的简单使用:
public class SynchronizedTest {private int i = 0; public synchronized void increment() { i++; } public synchronized int getCount() { return i; }}
(2) Lock 接口
Lock接口提供了比synchronized更灵活的锁机制,常用的实现类有 ReentrantLock 可重入锁。
下面的代码是Lock关键字的简单使用:
import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;public class LockCounter {private int count = 0;private final Lock lock = new ReentrantLock(); public void increment() { lock.lock(); try { count++; } finally { lock.unlock(); } } public int getCount() { lock.lock(); try { return count; } finally { lock.unlock(); } }}
(3) 原子类
Java提供了一些原子类,如 AtomicInteger、AtomicLong 和 AtomicReference,它们通过CAS(Compare-And-Swap)操作实现了非阻塞的线程安全。
下面的代码是AtomicInteger原子类的简单使用:
import java.util.concurrent.atomic.AtomicInteger;public class AtomicTest {private AtomicInteger atomic = new AtomicInteger(); public void increment() { atomic.incrementAndGet(); } public int getCount() { return atomic.get(); }}
(4) ThreadLocal 类
ThreadLocal类提供了线程局部变量,每个线程都有自己独立的变量副本,从而避免了共享数据的竞争。
下面的代码是ThreadLocal类的简单使用:
public class ThreadLocalExample {private static final ThreadLocal<Integer> threadLocal = ThreadLocal.withInitial(() -> 1); public int getValue() { return threadLocal.get(); } public void setValue(int value) { threadLocal.set(value); }}
(5) 分布式锁
Redis 分布式锁 或者 Zookeeper分布式锁是分布式环境下保证线程安全的常用方法。关于两种分布式锁的原理,会在其他的文章详细分析。
线程安全是 Java多线程编程中很重要的一部分,本文讲解了什么是线程安全以及产生线程安全问题的根因,并且通过原子性,有序性,可见性对线程安全进行了分析。
本文链接://www.dmpip.com//www.dmpip.com/showinfo-26-89393-0.html到底什么是线程安全? 如何保证线程安全?
声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com