如何在Java中实现线程同步 Java同步机制与关键字详解-java教程-PHP中文网

在java中实现线程同步的目的是确保多线程环境下共享资源的并发访问安全，避免竞态条件、数据不一致等问题。1. synchronized关键字适用于简单同步场景，通过锁定对象或类实现方法或代码块的同步，但其锁不可中断且粒度较粗；2. volatile关键字保证变量的可见性，适用于状态标志等无需原子性的场景，但不能保证复合操作的原子性；3. java.util.concurrent.locks包（如reentrantlock）提供更灵活的锁机制，支持尝试获取锁、可中断锁、公平锁等高级特性，适用于需要细粒度控制的复杂并发场景。此外，应避免死锁、合理使用wait/notify、选择合适的锁粒度，并优先使用j.u.c包中的并发工具提升程序健壮性。

如何在Java中实现线程同步 Java同步机制与关键字详解

在Java中实现线程同步，核心在于管理多线程对共享资源的并发访问，以避免数据不一致或竞态条件。这主要通过synchronized关键字、volatile关键字以及java.util.concurrent.locks包下的各种锁机制来实现。理解它们的原理和适用场景，是写出健壮多线程程序的关键。

解决方案

Java提供了一系列强大的工具来处理线程同步问题，每种都有其独特的优势和适用场景。

1. synchronized 关键字： 这是Java内置的同步机制，也是最常用的一种。它可以修饰方法或代码块。

修饰实例方法： 当synchronized修饰一个非静态方法时，它锁定的是当前实例对象（this）。这意味着同一时间只有一个线程可以执行该对象的这个同步方法。

立即学习“Java免费学习笔记（深入）”；
```
class Counter {
    private int count = 0;

    public synchronized void increment() {
        count++;
    }

    public synchronized int getCount() {
        return count;
    }
}
```
登录后复制
这里，increment和getCount方法都是同步的，它们共享同一个锁——Counter实例本身。
修饰静态方法： 当synchronized修饰一个静态方法时，它锁定的是当前类的Class对象。这意味着同一时间只有一个线程可以执行该类的任何一个静态同步方法。
```
class StaticCounter {
    private static int count = 0;

    public static synchronized void increment() {
        count++;
    }
}
```
登录后复制
静态方法锁的是类，而不是实例。
修饰代码块： 这是最灵活的方式，你可以指定任何对象作为锁。它允许我们只同步代码中需要同步的特定部分，而不是整个方法，从而提高并发性。
```
class BlockCounter {
    private int count = 0;
    private final Object lock = new Object(); // 专门的锁对象

    public void increment() {
        synchronized (lock) { // 锁定lock对象
            count++;
        }
    }

    public int getCount() {
        synchronized (lock) { // 同样锁定lock对象
            return count;
        }
    }
}
```
登录后复制
使用代码块同步时，选择一个私有的final对象作为锁是推荐的做法，这样可以防止外部代码意外地获取到你的锁，造成不可预知的行为。synchronized的底层是基于JVM的监视器锁（Monitor Lock），它具有可重入性，即如果一个线程已经持有了某个对象的锁，它再次尝试获取这个对象的锁时，仍然可以成功。

2. volatile 关键字：volatile关键字用于保证变量的可见性。当一个变量被volatile修饰时，对这个变量的修改会立即被写入主内存，并且当其他线程读取这个变量时，会强制从主内存中读取最新值，而不是从自己的工作内存（CPU缓存）中读取旧值。

主要作用： 确保共享变量的修改对所有线程立即可见。
局限性： volatile只能保证可见性，不能保证操作的原子性。例如，volatile int i = 0; i++;这个操作就不是原子性的，因为它包含了读取、修改、写入三个步骤。
```
class FlagExample {
    private volatile boolean running = true;

    public void stop() {
        running = false; // 修改会立即写入主内存
    }

    public void run() {
        while (running) { // 每次读取都从主内存获取最新值
            // do something
        }
        System.out.println("Thread stopped.");
    }
}
```
登录后复制
volatile适用于那些只需要保证可见性而不需要原子性操作的场景，比如作为线程间通信的标志位。

3. java.util.concurrent.locks 包（J.U.C 包）： 这个包提供了比synchronized更灵活、更高级的锁机制，比如ReentrantLock、ReadWriteLock等。

ReentrantLock： 它是Lock接口的一个实现，提供了与synchronized类似的功能，但更加灵活。
- 显式锁定与解锁： 需要手动调用lock()获取锁，并在finally块中调用unlock()释放锁，以确保即使发生异常也能释放锁。
- 可中断锁： lockInterruptibly()允许在等待锁时响应中断。
- 尝试非阻塞获取锁： tryLock()方法可以尝试获取锁，如果获取不到立即返回false，不会一直等待。
- 公平性： 可以通过构造函数指定为公平锁（new ReentrantLock(true)），公平锁会保证等待时间最长的线程优先获取锁，但会牺牲一些性能。
- 条件变量： 可以通过newCondition()创建条件对象，结合await()、signal()、signalAll()实现更复杂的线程协作（类似于Object的wait()、notify()、notifyAll()）。
```
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
```
  登录后复制
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();
    }
}
```
登录后复制
}
```
`ReentrantLock`在需要更细粒度控制、更复杂同步策略时非常有用。
```
登录后复制

为什么在多线程环境下我们需要线程同步？

说实话，这个问题问得挺直接的，但它背后隐藏着多线程编程中最让人头疼的几个痛点。我们之所以需要线程同步，根本原因在于现代计算机的架构和多任务处理的需求。当多个线程同时访问和修改同一个共享资源（比如一个变量、一个文件、一个数据库连接）时，如果没有合适的机制来协调它们的访问顺序，就很容易出现以下问题：

竞态条件（Race Condition）： 这是最常见的问题。多个线程尝试同时对一个共享资源进行读写操作，最终结果取决于线程执行的相对时序。举个例子，一个简单的i++操作，在底层实际上是三步：1. 读取i的值；2. 将i的值加1；3. 将新值写回i。如果线程A读取了i的值（比如是5），还没来得及写回6，线程B也读取了i的值（也是5），然后两个线程都各自计算出6并写回，那么i最终的值就只增加了1，而不是预期的2。这就是数据不一致。
数据不一致性： 竞态条件直接导致的结果。你期望的数据状态，因为并发访问而变得混乱，与预期不符。这在业务逻辑中是灾难性的，比如银行账户余额计算错误，库存数量出错等等。

腾讯智影-AI数字人
基于AI数字人能力，实现7*24小时AI数字人直播带货，低成本实现直播业务快速增增，全天智能在线直播

73

查看详情
死锁（Deadlock）： 多个线程互相等待对方释放资源，导致所有线程都无法继续执行。这就像两个人各自拿着一把钥匙，但需要对方的钥匙才能打开门，结果谁也不让谁，都僵在那里了。死锁一旦发生，程序就卡住了，无法恢复。
活锁（Livelock）： 比死锁稍微好一点，但也好不到哪去。线程虽然没有阻塞，但它们不断地改变自己的状态，试图避免冲突，结果却陷入了一个无限循环，谁也无法完成实际工作。想象两个人互相谦让，都想让对方先过门，结果谁也进不去。
饥饿（Starvation）： 某个线程或某些线程由于优先级低、运气差或者调度策略不公平，一直无法获取到所需的资源，导致其任务永远无法完成。它一直在“等待”，但永远等不到。

总而言之，线程同步不是为了让程序跑得更快（有时甚至会降低性能），而是为了保证程序在多线程环境下的正确性和健壮性。这是多线程编程中最基础也是最重要的原则。

`synchronized`、`volatile` 和 `Lock` 机制各自的适用场景与局限性是什么？

这三者在Java并发编程中就像是不同的工具，各有各的用武之地，也各有各的短板。理解它们，就能在实际开发中做出更合适的选择。

1. synchronized 关键字：

适用场景：
- 简单且小型的临界区： 当你需要快速、直接地保护一小段代码或一个方法，防止并发访问时，synchronized是最简洁的选择。
- 内置锁： Java语言层面直接支持，不需要额外的类库导入，用起来很方便。
- 可重入性： 如果一个线程已经持有了锁，它可以再次进入这个锁保护的区域，避免了死锁。这在递归调用或内部方法调用时非常有用。
- 与wait()/notify()/notifyAll()配合： Object类提供的这三个方法必须在synchronized块内部调用，用于实现线程间的协作通信。
局限性：
- 粗粒度： synchronized是悲观锁，一旦一个线程获取了锁，其他所有试图获取该锁的线程都会被阻塞，直到锁被释放。这可能会降低程序的并发度。
- 无法中断： 一个线程如果被阻塞在synchronized锁的获取上，它是无法响应中断的。这意味着你无法优雅地停止一个正在等待锁的线程。
- 无法尝试非阻塞获取锁： synchronized没有提供类似tryLock()的方法，你无法尝试获取锁，如果获取不到就立即返回。它要么成功获取锁，要么一直阻塞。
- 无法实现公平锁： synchronized的锁是非公平的，无法保证等待时间最长的线程优先获取锁。
- 不灵活： 锁的释放是隐式的（方法或代码块执行完毕或抛出异常），无法手动控制锁的获取和释放时机。

2. volatile 关键字：

适用场景：
- 可见性保证： 当一个变量被多个线程共享，并且它的修改需要立即使其他线程可见时，volatile是最佳选择。
- 状态标志： 比如一个boolean类型的shutdown标志，一个线程修改它，另一个线程循环检查它来决定是否停止。
- 双重检查锁定（DCL）的修正： 在单例模式的DCL实现中，volatile可以确保实例的正确初始化顺序，防止指令重排导致的问题（虽然现在更推荐用静态内部类或枚举实现单例）。
- 开销极低： 相比于synchronized或Lock，volatile的开销非常小，因为它不涉及线程上下文切换或调度。
局限性：
- 不保证原子性： 这是它最大的局限。volatile不能用于复合操作（如i++），因为它只保证单个读写操作的可见性，不保证这些操作作为一个整体的原子性。
- 不能替代锁： 如果需要对共享变量进行原子性的修改（例如，一个计数器），或者需要保护一段包含多个操作的临界区，volatile是不足够的，必须使用锁。
- 仅适用于变量： 只能修饰变量，不能修饰方法或代码块。

3. java.util.concurrent.locks 包（特别是 ReentrantLock）：

适用场景：
- 更细粒度的控制： 当你需要比synchronized更灵活的锁控制时，ReentrantLock是首选。你可以手动控制锁的获取和释放时机。
- 可中断的锁获取： 当线程在等待锁时，你可以中断它，让它停止等待，这对于长时间运行或需要响应取消操作的线程非常重要。
- 非阻塞地尝试获取锁： tryLock()方法允许你尝试获取锁，如果失败，可以立即执行其他操作，而不是无限期等待。
- 公平性需求： 当你需要保证等待时间最长的线程优先获取锁，以避免饥饿问题时，可以创建公平锁（new ReentrantLock(true)）。
- 条件变量（Condition）： 当需要实现更复杂的线程间协作（生产者-消费者模式等）时，ReentrantLock结合Condition对象提供了比wait()/notify()更强大的功能，可以实现多组等待/通知。
- 读写锁（ReadWriteLock）： 如果你的应用读操作远多于写操作，ReadWriteLock可以大大提高并发性。它允许多个读线程同时访问，但写线程必须独占。
局限性：
- 手动管理锁： ReentrantLock需要手动调用lock()和unlock()，这增加了编程的复杂性，并且很容易忘记在finally块中释放锁，导致死锁或资源泄露。
- 更长的学习曲线： 相比于synchronized的直观，J.U.C包的锁机制需要更深入的理解。
- 性能开销： 虽然在某些高并发场景下ReentrantLock可能比synchronized表现更好，但其本身的开销也略高于synchronized。

选择哪种机制，很大程度上取决于具体的并发场景、对性能和灵活性的要求。简单场景用synchronized足够，需要精细控制或解决特定问题时，volatile或J.U.C包的锁会是更好的选择。

如何避免常见的线程同步陷阱，提升多线程程序的健壮性？

在多线程编程中，仅仅知道同步机制是不够的，还需要学会如何规避那些“坑”。写出健壮的多线程代码，很多时候就是避免这些常见的陷阱。

1. 避免死锁： 死锁是多线程编程中最让人头疼的问题之一，一旦发生，程序就“卡死”了。要避免它，通常可以从死锁的四个必要条件入手：互斥、请求与保持、不可剥夺、循环等待。我们能做的就是破坏其中一个或多个条件。

固定加锁顺序： 这是最有效且常用的策略。如果你的线程需要获取多个锁，始终按照一个预定义的、全局一致的顺序来获取它们。例如，总是先获取A锁，再获取B锁。这样就能打破循环等待条件。
使用tryLock()和超时机制： 使用ReentrantLock的tryLock(long timeout, TimeUnit unit)方法，尝试在一定时间内获取锁。如果超时仍未获取到，就放弃当前操作，或者释放已持有的锁，然后重试。这可以有效避免无限等待。
一次性获取所有锁： 尝试一次性获取所有需要的锁。如果不能全部获取，就全部释放，然后重试。这通常通过一个循环来实现，直到所有锁都被获取。
避免在持有锁时进行耗时操作： 尽量缩短锁的持有时间。在持有锁的临界区内，只执行必要的原子操作，避免进行I/O操作、网络请求等耗时操作。

2. 谨慎使用wait()、notify()和notifyAll()： 这些方法是Object类的一部分，用于线程间的协作，但使用不当很容易出错。

总是在循环中检查条件： 当一个线程调用wait()等待某个条件满足时，它应该在一个while循环中检查这个条件。这是因为线程可能会被“虚假唤醒”（spurious wakeup），即在条件未满足时被唤醒。
```
synchronized (lock) {
    while (conditionIsNotMet) {
        lock.wait();
    }
    // 条件满足，执行操作
}
```
登录后复制
使用notifyAll()而非notify()： 除非你非常确定只有一个线程在等待，否则优先使用notifyAll()来唤醒所有等待的线程。notify()只唤醒一个任意等待的线程，这可能导致错误的线程被唤醒，或者导致其他线程永远无法被唤醒（饥饿）。
在synchronized块内部调用： wait()、notify()和notifyAll()必须在持有对象锁的synchronized块内部调用，否则会抛出IllegalMonitorStateException。

3. 锁的粒度选择： 锁的粒度（Lock Granularity）是指锁保护的范围大小。

太粗的粒度： 如果锁保护的范围太大，例如同步整个方法甚至整个类，虽然可以确保线程安全，但会大大降低并发性，因为同一时间只有一个线程能执行大部分代码。这就像把整个图书馆都锁起来，每次只允许一个人进去借书。
太细的粒度： 如果锁保护的范围太小，虽然提高了并发性，但可能会增加锁的获取和释放开销，甚至可能导致更复杂的竞态条件（因为你可能漏掉了某些需要同步的代码）。这就像每本书都有一个锁，管理起来非常复杂。
最佳实践： 尽可能使用细粒度锁，只锁定需要保护的共享资源，且锁定时间越短越好。但同时要确保所有需要协作的共享资源都在同一个锁的保护之下。例如，对于一个包含多个字段的对象，如果这些字段之间存在依赖关系，那么对这些字段的修改操作应该在同一个锁的保护下进行。

4. 避免对可变静态字段的非同步访问： 静态字段是所有线程共享的，如果它是可变的且没有适当的同步，那么就可能出现线程安全问题。这就像一个公共黑板，所有人都可以在上面写写画画，但如果同时有几个人写，字就乱了。

5. 优先使用J.U.C包中的高级并发工具： 在许多复杂的场景下，java.util.concurrent包提供了许多比synchronized更强大、更灵活、性能更好的并发工具。

Atomic类： 对于简单的原子操作（如AtomicInteger、AtomicLong、AtomicReference），它们使用CAS（Compare-And-Swap）操作，在不使用锁的情况下保证原子性，性能通常优于锁。
ConcurrentHashMap： 在多线程环境下，使用ConcurrentHashMap替代HashMap或Hashtable，因为它提供了高并发的读写性能。
CountDownLatch、CyclicBarrier、Semaphore： 这些工具用于更复杂的线程协作和控制。