1

假设我有一个线程安全的集合，我将按以下方式填充它：

   Set set = new HashSet();
   for (Map map : maps) {
        set.addAll(doSomeExpensiveProcessing(map.keySet()));
    }

同时执行此操作的最佳方式是什么？（即每个地图将同时将其键添加到集合中。

编辑 - 我知道 HashSet 不是线程安全的，但就我而言，这超出了问题的范围。

EDIT2 - 正确地指出，对于这个特定的场景，并发不会获得巨大的好处，但是会有额外的步骤，我现在已经包含在代码示例中。

4

3 回答 3

2

这应该有效：

// NB - Be sure to use a concurrent form of Set here.
Set set = new HashSet();
ArrayList<Map> maps = new ArrayList<>();

public void test() {
  for (final Map map : maps) {
    new Thread(new Runnable() {
      @Override
      public void run() {
        set.addAll(map.keySet());
      }
    }).start();
  }
}

我意识到您对并发的实现不感兴趣，HashSet但为了完整起见，我想提一下这些选项。

您可以考虑 a ConcurrentSkipListSetif your objects implement Comparable，或者 aCollections.newSetFromMap(new ConcurrentHashMap<Object,Boolean>())会做。

于 2013-05-21T15:09:35.217 回答
1

虽然@OldCurmudgeon 有一个很好的基本方法，但在更严肃的代码中，您可能想要制作一个Callable对密钥进行昂贵处理并返回一个新的Collection. 这可以与 Executor 和/或 CompletionService 结合使用。最后，您甚至不需要并发集合。

例如，如果键是字符串

public class DoesExpensiveProcessing implements Callable<Set<String>> {

   final Set<String> inKeys;

   public DoesExpensiveProcessing(Set<String> keys) {
     this.inKeys = keys;  // make a defensive copy if required...
   }

   public Set<String> call() {
      // do expensive processing on inKeys and returns a Set of Strings
   }
}

此时您甚至不需要并行集合

List<DoesExpensiveProcessing> doInParallel = new ArrayList<DoesExpensiveProcessing>();
for (Map map : maps) {
   doInParallel.add(new DoesExpensiveProcessing(map.keySet()));
}

Set theResultingSet = new HashSet<String>();
List<Future<Set<String>>> futures = someExecutorService.invokeAll(doInParallel);
for (Future<Set<String>> f : futures) {
  theResultingSet.addAll(f.get());
}
于 2013-05-21T16:32:25.113 回答
0

这样它就不会是并发的，但至少是线程安全的：

Set set = Collections.synchronizedSet(new HashSet());
...
// in some other threads:
for (Map map : maps) {
  set.addAll(map.keySet());
}

还是您更喜欢以下内容：

ConcurrentMap<Object, Boolean> set = new ConcurrentHashMap<Object, Boolean>();
...
// in some other threads:
for (Map map : maps) {
  for (Object o : map.keySet()) {
    set.putIfAbsent(o, true);
  }
}
于 2013-05-21T15:26:05.397 回答