Java中如何避免并发控制不当导致数据不一致-向日葵屋

Java中如何避免并发控制不当导致数据不一致

在Java中，避免并发控制不当导致数据不一致，可以采取以下几种策略：

使用synchronized关键字：当对共享资源进行操作时，可以使用synchronized关键字来确保同一时间只有一个线程访问该资源。

public class Counter {
    private int count = 0;
    public synchronized void increment() {
        count++;
    }
    public synchronized int decrement() {
        if (count > 0) {
            count--;
            return count;
        }
        throw new IllegalArgumentException("Counter underflow");
    }
    public synchronized int getCount() {
        return count;
    }
}

使用Lock接口：除了synchronized，Java还提供了更高级别的锁，如ReentrantLock。

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class CounterWithLock {
    private int count = 0;
    private Lock lock = new ReentrantLock();
    public void increment() {
        lock.lock();
        try {
            count++;
        } finally {
            lock.unlock();
        }
    }
    public int decrement() {
        lock.lock();
        try {
            if (count > 0) {
                count--;
                return count;
            }
        } finally {
            lock.unlock();
        }
        throw new IllegalArgumentException("Counter underflow");
    }
    public int getCount() {
        lock.lock();
        try {
            return count;
        } finally {
            lock.unlock();
        }
    }
}

使用ConcurrentHashMap：对于键值对类型的并发数据，可以使用ConcurrentHashMap，它提供了线程安全的访问方式。

import java.util.concurrent.ConcurrentHashMap;
public class CounterWithMap {
    private ConcurrentHashMap<String, Integer> countMap = new ConcurrentHashMap<>();
    public void increment(String key) {
        countMap.computeIfAbsent(key, k -> 0));
        countMap.put(key, countMap.get(key) + 1);
    }
    public int decrement(String key) {
        countMap.compute(key, (v, null) -> v - 1));
        if (countMap.get(key) < 0) {
            throw new IllegalArgumentException("Counter underflow");
        }
        return countMap.get(key);
    }
    public int getCount(String key) {
        return countMap.getOrDefault(key, 0));
    }
}