简单聊聊 Java 中线程安全有哪些实现思路?

在 Java 多线程编程中，线程安全是一个非常重要的概念。 线程安全通常指程序在多线程并发执行时，仍然能够保持正确的行为。 Java 提供了很多实现线程安全的方法，本文将介绍几种常见的实现思路。

1、使用 synchronized 关键字

synchronized 关键字是 Java 中最基本的解决线程安全问题的方法，它可以确保代码块以原子方式执行。 synchronized 可以用来修饰实例方法、静态方法和代码块。 下面是 synchronized 修饰实例方法的示例代码：

public class Counter {    private int count;
    public synchronized void increment() {        count++;    }
    public synchronized int getCount() {        return count;    }}

在上述代码中，increment() 和 getCount() 方法都被 synchronized 修饰，这样就可以保证每次只有一个线程能够访问它们。这种方法虽然简单，但是它的效率相对较低，因为每次只能有一个线程访问这些方法。

2、使用 ReentrantLock 类

Java 中的 ReentrantLock 类提供了比 synchronized 更灵活的线程同步机制。ReentrantLock 具有可重入性，可以中断等待锁的线程，以及通过 tryLock() 方法尝试获取锁等特性。 下面是使用 ReentrantLock 实现线程安全的示例代码：

import java.util.concurrent.locks.ReentrantLock;
public class Counter {    private int count;    private ReentrantLock lock = new ReentrantLock();
    public void increment() {        lock.lock();        try {            count++;        } finally {            lock.unlock();        }    }
    public int getCount() {        lock.lock();        try {            return count;        } finally {            lock.unlock();        }    }}

在上述代码中，使用 lock.lock() 获取锁，使用 lock.unlock() 释放锁。使用 ReentrantLock 时需要注意的是，获取锁和释放锁的逻辑必须放在 try-finally 块中，确保锁一定能够被正确释放。

3、使用 ConcurrentHashMap 类

ConcurrentHashMap 是 Java 中的线程安全哈希表实现。 ConcurrentHashMap 使用分段锁机制，将整个哈希表分为多个段，不同段的元素可以同时被多个线程访问。 下面是使用 ConcurrentHashMap 实现线程安全的示例代码：

import java.util.concurrent.ConcurrentHashMap;
public class Counter {    private ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>();
    public void increment(String key) {        map.put(key, map.getOrDefault(key, 0) + 1);    }
    public int getCount(String key) {        return map.getOrDefault(key, 0);    }}

在上述代码中，使用 ConcurrentHashMap 存储计数器的值，使用 map.put() 和 map.getOrDefault() 方法更新和获取计数器的值。由于 ConcurrentHashMap 是线程安全的，所以这种实现方式可以保证多个线程同时访问时计数器的值是正确的。

4、使用 Atomic 类

Java 中的 Atomic 类提供了一组原子操作，可以确保操作是以原子方式进行的。 Atomic 类包括 AtomicBoolean、AtomicInteger、AtomicLong 等。下面是使用 AtomicInteger 实现线程安全的示例代码：

import java.util.concurrent.atomic.AtomicInteger;
public class Counter {    private AtomicInteger count = new AtomicInteger();
    public void increment() {        count.incrementAndGet();    }
    public int getCount() {        return count.get();    }}

在上述代码中，使用 AtomicInteger 存储计数器的值，使用 count.incrementAndGet() 方法更新计数器的值。由于 AtomicInteger 是线程安全的，所以这种实现方式可以保证多个线程同时访问时计数器的值是正确的。

5、使用 ThreadLocal 类

ThreadLocal 类可以让每个线程拥有自己的变量副本，在多个线程并发执行时，每个线程都可以独立地操作自己的变量副本，从而避免了线程安全问题。下面是使用 ThreadLocal 实现线程安全的示例代码：

public class Counter {    private ThreadLocal<Integer> threadLocal = ThreadLocal.withInitial(() -> 0);
    public void increment() {        threadLocal.set(threadLocal.get() + 1);    }
    public int getCount() {        return threadLocal.get();    }}

在上述代码中，使用 ThreadLocal 类存储计数器的值，使用 threadLocal.set() 和 threadLocal.get() 方法更新和获取计数器的值。由于每个线程都有自己的变量副本，所以这种实现方式可以保证多个线程同时访问时计数器的值是正确的。

总结一下

本文介绍了 Java 中几种实现线程安全的方法，包括 synchronized 关键字、ReentrantLock 类、ConcurrentHashMap 类、Atomic 类、ThreadLocal 类等。每种方法都有其特点和适用场景，需要根据实际需求选择合适的方法。在实际应用中，为了更好地提高系统的性能和并发能力，可以组合使用多种方法来实现线程安全。

作者：Cosolar

链接：https://juejin.cn/post/7232284746134257723

来源：稀土掘金