java - 使用 ConcurrentMap 双重检查锁定

Question

我有一段代码可以由多个线程执行，该代码需要执行 I/O 绑定(bind)操作，以便初始化存储在 ConcurrentMap 中的共享资源。我需要使这段代码线程安全，并避免不必要的调用来初始化共享资源。这是有错误的代码:

    private ConcurrentMap<String, Resource> map;

    // .....

    String key = "somekey";
    Resource resource;
    if (map.containsKey(key)) {
        resource = map.get(key);
    } else {
        resource = getResource(key); // I/O-bound, expensive operation
        map.put(key, resource);
    }

使用上面的代码，多个线程可能会检查 ConcurrentMap 并发现资源不存在，并且所有线程都会尝试调用 getResource() ，这是昂贵的。为了确保共享资源仅进行一次初始化，并在资源初始化后使代码高效，我想做这样的事情:

    String key = "somekey";
    Resource resource;
    if (!map.containsKey(key)) {
        synchronized (map) {
            if (!map.containsKey(key)) {
                resource = getResource(key);
                map.put(key, resource);
            }
        }
    }

这是双重检查锁定的安全版本吗？在我看来，由于检查是在 ConcurrentMap 上调用的，因此它的行为就像被声明为 volatile 的共享资源，从而防止任何“部分初始化”问题这可能会发生。

Answer 1

如果你可以使用外部库，看看Guava的MapMaker.makeComputingMap() 。它是为您想要做的事情量身定制的。