java线程如何同步
线程同步的方法
在Java中，线程同步可以通过多种方式实现，主要目的是控制多个线程对共享资源的访问，避免数据不一致或竞态条件。以下是几种常见的线程同步方法：
使用synchronized关键字
synchronized可以修饰方法或代码块，确保同一时间只有一个线程可以执行被修饰的代码。
// 同步方法
public synchronized void synchronizedMethod() {
// 线程安全的代码
}
// 同步代码块
public void someMethod() {
synchronized (this) {
// 线程安全的代码
}
}使用ReentrantLock
ReentrantLock是java.util.concurrent.locks包中的一个类，提供了比synchronized更灵活的锁机制。
import java.util.concurrent.locks.ReentrantLock;
private final ReentrantLock lock = new ReentrantLock();
public void someMethod() {
lock.lock();
try {
// 线程安全的代码
} finally {
lock.unlock();
}
}使用volatile关键字
volatile关键字确保变量的可见性，即当一个线程修改了volatile变量的值，其他线程能立即看到最新的值。
private volatile boolean flag = false;
public void setFlag(boolean value) {
flag = value;
}
public boolean getFlag() {
return flag;
}使用Atomic类
java.util.concurrent.atomic包提供了一系列原子操作类，如AtomicInteger、AtomicLong等，可以确保对变量的操作是原子性的。
import java.util.concurrent.atomic.AtomicInteger;
private AtomicInteger counter = new AtomicInteger(0);
public void increment() {
counter.incrementAndGet();
}使用CountDownLatch
CountDownLatch允许一个或多个线程等待其他线程完成操作。
import java.util.concurrent.CountDownLatch;
CountDownLatch latch = new CountDownLatch(3);
// 线程中调用
latch.countDown();
// 等待其他线程完成
latch.await();使用CyclicBarrier
CyclicBarrier允许多个线程相互等待，到达屏障点后再继续执行。
import java.util.concurrent.CyclicBarrier;
CyclicBarrier barrier = new CyclicBarrier(3);
// 线程中调用
barrier.await();使用Semaphore
Semaphore用于控制同时访问特定资源的线程数量。
import java.util.concurrent.Semaphore;
Semaphore semaphore = new Semaphore(3);
// 线程中调用
semaphore.acquire();
// 访问资源
semaphore.release();选择合适的同步方法
- 简单同步：使用
synchronized关键字。 - 灵活锁机制：使用
ReentrantLock。 - 可见性需求：使用
volatile关键字。 - 原子操作：使用
Atomic类。 - 线程协调：使用
CountDownLatch或CyclicBarrier。 - 资源限制：使用
Semaphore。
根据具体场景选择合适的同步方法，可以有效避免线程安全问题。
