Java上Redis散列中的列表

Question

public void put(String hashName, int key , List<myObj> myList) {
        redis.opsForHash().put(hashName, String.valueOf(key), myList);
        }

public List<myObj> get(String hashName, string key) {
    Object map = redis.opsForHash().get(hashName,key);
    if (map==null) {
        log.info("no keys found");
        return new ArrayList<myObj>();
    }
    List<myObj> myList= mapper.convertValue(map, new TypeReference<List<myObj>(){});
    return myList;
}

执行更新的操作是：

List<myObj> myList= hash.get(hashName,key);
myList.add(obj);
hash.put(hashName, key, myList);

当有多个实例时，我出现在竞争条件下。有没有一种方法以原子的方式更新列表值？

Answer 1

您当前的实现并不好，因为在put()中您更新了整个列表。如果许多线程想要向列表中添加一个元素，它们首先获得当前列表，然后添加一个元素，然后放入新的列表。每个线程将重写前一个线程的结果，最后一个线程获胜。synchronized的用法在这里无关紧要。

解决方案

不要替换整个列表。相反，向列表中添加一个元素。删除put()方法，并添加一个新方法，如下所示：

public synchronized void add(String hashName, int key, myObj element) {
    List<myObj> myList;
    Object map = redis.opsForHash().get(hashName,key);
    if (map != null) {
        myList= mapper.convertValue(map, new TypeReference<List<myObj>(){});
    } else {
        myList = new ArrayList<myObj>();
    }
    myList.add(element);
    redis.opsForHash().put(hashName, String.valueOf(key), myList);
}

public List<myObj> get(String hashName, string key) {
    Object map = redis.opsForHash().get(hashName,key);
    if (map==null) {
        log.info("no keys found");
        return new ArrayList<myObj>();
    }
    List<myObj> myList= mapper.convertValue(map, new TypeReference<List<myObj>(){});
    return Collections.unmodifiableList(myList);
}