2

我正在学习Java Concurrency in Practice，但一些代码让我感到困惑：

private final ConcurrentHashMap<A, Future<V>> cache = new ConcurrentHashMap<A, Future<V>>();

private final Computable<A, V> c;

public Memoizer(Computable<A, V> c) {
    this.c = c;
}

/* (non-Javadoc)
 * @see com.demo.buildingblocks.Computable#compute(java.lang.Object)
 */
@Override
public V compute(final A arg) throws InterruptedException {

    while (true) {
        Future<V> f = cache.get(arg);
        if (f == null) {
            // 
            Callable<V> eval = new Callable<V>() {
                @Override
                public V call() throws Exception {
                    return c.compute(arg);
                }
            };
            FutureTask<V> ft = new FutureTask<V>(eval);
            // what will happen when two threads arrive here at the same time?
            f = cache.putIfAbsent(arg, ft);
            if (f == null) {
                f = ft;
                ft.run();
            }
        }
        try {
            return f.get();
        } catch (CancellationException e) {
            cache.remove(arg, f);
        } catch (ExecutionException e) {
            launderThrowable(e);
        }
    }
}

我就是不明白，既然putIfAbsent只能保证put操作是原子的，而且都返回null，如果两个线程都可以进入run方法呢？

4

2 回答 2

1

所有原子实现的来源都是compareAndSet(expected, newValue)方法。因此，如果 2 个线程到达并且每个线程都喜欢设置一个位于 - 比如说 - 1 到 3 的元素，则会发生以下情况：

Thread A: value.compareAndSet(1, 3) - success: value is now 3, return true.
Thread B: value.compareAndSet(1, 3) - error: value is not 1 as expected, return false.

哪个线程先到达是未定义的，但由于 compareAndSet 是一个原子函数，因此可以保证线程在执行时不会相互干扰。

于 2013-11-24T11:07:35.693 回答
1

putIfAbsent保证线程安全不仅在它不会破坏您的数据的意义上，而且在它始终在数据的最新副本上工作的意义上。

此外，如果存在这样的值，它不会返回地图中的前一个值。所以第一次调用putIfAbsent会成功，并返回null，因为没有以前的值。第二个调用将阻塞，直到第一个成功，然后返回放入映射中的第一个值，导致第二个run()永远不会被调用。

于 2013-11-24T07:00:49.513 回答