(初步说明:也许这更适合 codereview ？)

编辑 Answer to self ;我相信这个答案涵盖了我所有的需求/问题，当然，欢迎发表评论。原问题留在下方以供引用。

你好，

此处感兴趣的是 .getSources() 方法。此方法旨在返回给定 Locale 的消息源列表。

此方法的两个核心数据结构是sources 和failedLookups，请参阅注释代码。

.getSources() 的这种特殊实现只能返回空列表或单元素列表，具体取决于原型(prototype)是哪个 tryAndLookup() 方法:

protected abstract MessageSource tryAndLookup(final Locale locale)
    throws IOException;

目前，代码逻辑如下:

• 如果已成功查找到该语言环境的消息源，则返回；
• 从现在开始，没有进行任何查找；然而，未知这是否意味着之前的查找尝试已经完成:检查失败查找集，如果要查找的语言环境在那里，则为已知失败，返回空列表；
• 现在，已知的情况是实际上从未执行过此区域设置查找:执行它；根据 tryAndLookup 方法的结果，记录成功或失败。

现在，为什么我要如此努力:我无法控制 tryAndLookup()；在返回有效源或失败之前执行可能需要过多的时间。因此，我不愿意使用粗糙的锁或 synchronized block 。

/**
 * Set of locales known to have failed lookup.
 *
 * <p>When a locale is in this set, it will not attempt to be reloaded.</p>
 */
private final Set<Locale> lookupFailures
    = new CopyOnWriteArraySet<Locale>();

/**
 * Set of message sources successfully looked up
 *
 * <p>When a source is in there, it is there permanently for now.</p>
 */
private final ConcurrentMap<Locale, MessageSource> sources
    = new ConcurrentHashMap<Locale, MessageSource>();

@Override
protected final List<MessageSource> getSources(final Locale locale)
{
    MessageSource source = sources.get(locale);

    /*
     * If found, return it
     */
    if (source != null)
        return Arrays.asList(source);

    /*
     * If it is a registered failure, return the empty list
     */
    if (lookupFailures.contains(locale))
        return Collections.emptyList();

    /*
     * OK, try and look it up. On success, register it in the sources map.
     * On failure, record the failure an return the empty list.
     */
    try {
        source = tryAndLookup(locale);
        sources.putIfAbsent(locale, source);
        // EDIT: fix for bug pinpointed by JBNizet
        // was:
        // return Arrays.asList(source);
        // now is:
        return Arrays.asList(sources.get(locale));
    } catch (IOException ignored) {
        lookupFailures.add(locale);
        return Collections.emptyList();
    }
}

我的问题有三个:

• 我有意将自己限制在仅适用于 JDK 的类上；我选择 ConcurrentHashMap 作为 ConcurrentMap 实现，CopyOnWriteArraySet 作为线程安全的 Set 实现；来自 javadoc，这些是我能找到的最好的。但是我在什么地方被误导了吗？
• 我认为这段代码最终是线程安全的；例如，某些极端情况可能会导致查找不止一次，但这就是我为什么要这样做的原因。现在我一直使用并信任 Guava 的 LoadingCache 用于缓存目的，这是我第一次涉足这个领域；这段代码实际上是线程安全的吗？
• 此代码有一个致命缺陷:多个线程可能同时执行 tryAndLookup()...有什么解决方案可以使此方法每次查找只执行一次？

最佳答案

作为 CopyOnWriteArraySet 的替代方案，您可以使用具有无意义值的 ConcurrentHashMap(例如，始终使用 Boolean.TRUE 作为值 -你只关心 key )，否则你可以使用 ConcurrentSkipListSet它本质上是一个并发的 TreeSet，它使用跳表而不是平衡二叉树。

假设 tryAndLookup 速度很快并且没有任何副作用，那么您是否偶尔会多次执行它并不重要，因为您的“最终线程安全”代码是线程安全的，因为它不会产生任何异常行为。 (如果它很慢，那么使用锁可能会更有效，以确保您尽可能少地执行它，但在这种情况下，您的代码仍然不会出现异常行为。如果它有副作用，那么您可能如果您在同一语言环境中执行两次，则会出现数据竞争。)

编辑 因为 tryAndLookup 可能有副作用，你可以在 locale 上同步，或者你可以修改你的方法如下

private final MessageSource nullSource = new MessageSource(); // Used in place of null in the ConcurrentHashMap, which does not accept null keys or values

protected final List<MessageSource> getSources(final Locale locale) {
...

    try {
        if(sources.putIfAbsent(locale, nullSource) == null) {
            source = tryAndLookup(locale);
            sources.replace(locale, nullSource, source);
            return Arrays.asList(sources.get(locale));
        } else {
            // Another thread is calling tryAndLookup, so wait for it to finish
            while(sources.get(locale) == nullSource && !lookupFailures.contains(locale))
                Thread.sleep(500);
            }
            if(sources.get(locale) != nullSource) {
                return Arrays.asList(sources.get(locale));
            } else {
                return Collections.emptyList();
            }
        }
    } catch (IOException ignored) {
        lookupFailures.add(locale);
        return Collections.emptyList();
    }
}

关于java - 仅使用 JDK (6) 提供的类来改进该代码的方法？ (并发、线程安全)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/16877409/