解决Java中并发控制不当导致的数据不一致问题-蒲公英云

解决Java中并发控制不当导致的数据不一致问题

原创墨蓝 2024-12-09 07:00 193阅读 0赞

在Java中，并发控制不当可能会引发数据不一致的问题。以下是一些常见的解决方案：

使用锁（synchronized）：同步块或方法可以保证同一时间只有一个线程访问代码块。例如：

public class Counter {
    private int count;
    public synchronized void increment() {
        count++;
    }
    public synchronized int decrement() {
        if (count > 0) {
            count--;
            return count;
        } else {
            throw new IllegalArgumentException("Can't decrement zero");
        }
    }
    // Getter
    public synchronized int getCount() {
        return count;
    }
}

使用并发容器（如ConcurrentHashMap）：这些容器提供了线程安全的访问方式。例如：

import java.util.concurrent.ConcurrentHashMap;
public class ThreadSafeCounter {
    private ConcurrentHashMap<String, Integer> counterMap = new ConcurrentHashMap<>();
    public synchronized int increment(String key) {
        return counterMap.computeIfAbsent(key, k -> 0))
                .incrementAndGet();
    }
    public synchronized int decrement(String key) {
        int count = counterMap.get(key);
        if (count > 0) {
            counterMap.put(key, count - 1);
            return count - 1;
        } else {
            counterMap.remove(key);
            throw new IllegalArgumentException("Can't decrement zero for " + key);
        }
    }
    // Getter
    public synchronized int getCount(String key) {
        return counterMap.getOrDefault(key, 0));
    }
}

使用原子类（Atomic classes）：Java 8引入了AtomicInteger, AtomicLong, 等原子类，它们提供了线程安全的原子操作。例如：

import java.util.concurrent.atomic.AtomicInteger;
public class ThreadSafeCounterWithAtomic {
    private AtomicInteger count = new AtomicInteger();
    public synchronized int increment() {
        return count.incrementAndGet();
    }
    public synchronized int decrement() {
        int value = count.getAndDec();
        if (value == 0) {
            throw new IllegalArgumentException("Can't decrement zero");
        }
        return value;
    }
    // Getter
    public synchronized int getCount() {
        return count.get();
    }
}