当前位置：首页 > Java

java如何控制并发

2026-03-03 23:43:28Java

控制并发的方法

Java提供了多种机制来控制并发，确保线程安全和高效执行。以下是几种常用的方法：

使用synchronized关键字

synchronized关键字用于修饰方法或代码块，确保同一时间只有一个线程可以访问被保护的资源。
示例代码：

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

或对代码块加锁：

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

使用Lock接口

java.util.concurrent.locks包中的Lock接口提供了更灵活的锁机制，例如ReentrantLock。
示例代码：

java如何控制并发

private final Lock lock = new ReentrantLock();
public void increment() {
    lock.lock();
    try {
        count++;
    } finally {
        lock.unlock();
    }
}

使用原子类

java.util.concurrent.atomic包提供了原子类（如AtomicInteger），通过CAS（Compare-And-Swap）操作实现无锁线程安全。
示例代码：

private AtomicInteger count = new AtomicInteger(0);
public void increment() {
    count.incrementAndGet();
}

使用线程安全集合

Java的并发包（java.util.concurrent）提供了线程安全的集合类，如ConcurrentHashMap、CopyOnWriteArrayList等。
示例代码：

java如何控制并发

ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>();
map.put("key", 1);

使用CountDownLatch

CountDownLatch用于等待多个线程完成操作后再继续执行主线程。
示例代码：

CountDownLatch latch = new CountDownLatch(3);
for (int i = 0; i < 3; i++) {
    new Thread(() -> {
        // 执行任务
        latch.countDown();
    }).start();
}
latch.await();

使用Semaphore

Semaphore用于控制同时访问资源的线程数量。
示例代码：

Semaphore semaphore = new Semaphore(3);
public void accessResource() {
    try {
        semaphore.acquire();
        // 访问资源
    } finally {
        semaphore.release();
    }
}

使用线程池

通过ExecutorService管理线程池，避免频繁创建和销毁线程的开销。
示例代码：

ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 10; i++) {
    executor.submit(() -> {
        // 执行任务
    });
}
executor.shutdown();