Java学习手册：Java线程安全与同步机制

## Java线程安全与同步机制

在Java并发编程中，线程安全和同步机制是确保程序正确性和数据一致性的关键。当多个线程同时访问共享资源时，如果不加以控制，可能会导致数据不一致、竞态条件等问题。本文将深入探讨Java中的线程安全问题以及解决这些问题的同步机制。

线程安全问题

线程安全问题通常出现在多个线程同时访问共享资源的情况下。常见的线程安全问题包括：

竞态条件（Race Conditions）：多个线程同时访问和修改共享数据，导致结果依赖于线程执行的顺序。
死锁（Deadlocks）：两个或多个线程因为等待对方释放资源而无法继续执行。
活锁（Livelocks）：线程不断尝试执行但无法取得进展。
数据不一致：线程看到的共享数据不是最新的。

同步代码块

Java提供了synchronized关键字，用于确保同一时间只有一个线程可以执行某个代码块。synchronized可以应用于方法或代码块。

同步方法

通过在方法前添加synchronized关键字，可以确保同一时间只有一个线程可以调用该方法。

示例代码：

public class BankAccount {private double balance;public synchronized void deposit(double amount) {if (amount > 0) {balance += amount;System.out.println("存入: " + amount + ", 余额: " + balance);}}public synchronized void withdraw(double amount) {if (amount > 0 && amount <= balance) {balance -= amount;System.out.println("取出: " + amount + ", 余额: " + balance);}}
}

同步代码块

通过在代码块前添加synchronized关键字和一个锁对象，可以确保同一时间只有一个线程可以执行该代码块。

示例代码：

public class BankAccount {private double balance;private final Object lock = new Object();public void deposit(double amount) {synchronized (lock) {if (amount > 0) {balance += amount;System.out.println("存入: " + amount + ", 余额: " + balance);}}}public void withdraw(double amount) {synchronized (lock) {if (amount > 0 && amount <= balance) {balance -= amount;System.out.println("取出: " + amount + ", 余额: " + balance);}}}
}

`synchronized`关键字

synchronized关键字是Java中最常用的同步机制之一。它通过对象的锁来确保同一时间只有一个线程可以执行同步代码块或方法。

`synchronized`方法

synchronized方法确保同一时间只有一个线程可以调用该方法。

示例代码：

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

`synchronized`代码块

synchronized代码块确保同一时间只有一个线程可以执行该代码块。

示例代码：

public class Counter {private int count = 0;private final Object lock = new Object();public void increment() {synchronized (lock) {count++;}}public int getCount() {synchronized (lock) {return count;}}
}

锁机制

Java提供了更灵活的锁机制，通过java.util.concurrent.locks.Lock接口及其实现类（如ReentrantLock）来管理锁。

示例代码：

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;public class Counter {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();}}
}

`volatile`关键字

volatile关键字用于确保变量的可见性，即一个线程对变量的修改对其他线程立即可见。

示例代码：

public class VolatileExample {private volatile boolean flag = false;public void setFlag(boolean flag) {this.flag = flag;}public boolean getFlag() {return flag;}public static void main(String[] args) {VolatileExample example = new VolatileExample();new Thread(() -> {while (!example.getFlag()) {// 等待flag变为true}System.out.println("Flag已变为true");}).start();try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}example.setFlag(true);}
}