异步for循环不挂

Question

我写了一个这样的同步for循环：

for (Map.Entry<String, CustomClass> entry : assocs.entrySet()) {
  String key = entry.getKey();
  CustomClass value = entry.getValue();
  value.tick(key);
}

问题是有时（很少）.tick 挂起。如果是单个.tick，没什么大不了的，它会在一段时间后自行修复，实际上根本不重要（这是由于客户端的互联网速度较慢）。但如果它耽误了其他人，那就是个问题了。

所以我希望每个循环体都运行而不等待其他循环体完成。

Answer 1

Andrew's solution 几乎是正确的，因为它使用了一个包含 10 个线程的固定线程池；如果assocs 中包含的元素超过 10 个，则第十一个元素可能会停止，因为它将与其余元素竞争线程。正确的方法是使用带有缓存线程池的ExecutorService：

ExecutorService service = Executors.newCachedThreadPool();

assocs.entrySet().forEach(entry -> {
    service.execute(() -> {
        String key = entry.getKey();
        CustomClass value = entry.getValue();
        value.tick(key);
    );
);

Answer 2

可能最简单的并行化方法是使用并行流：

 assocs.entrySet().parallelStream()
     .forEach(e -> e.getValue().tick(e.getKey()));

但请注意，这将使用ForkJoinPool.commonPool 来执行您的线程，该线程比您拥有的处理器少一个。

如果你想增加并行度，你总是可以在自己的 ForkJoinPool 中运行

new ForkJoinPool(numberOfThreads).submit(() ->
    assocs.entrySet().parallelStream()
        .forEach(e -> e.getValue().tick(e.getKey())));

Answer 3

说实话，创建 ExecutorService 比手动管理自己的线程要简单：

final ExecutorService exec = Executors.newFixedThreadPool(10);

//create a list of Futures, so you know when each tick is done
final List<Future> futures = new ArrayList<>();
for (final Map.Entry<String, CustomClass> entry : assocs.entrySet()) {
  final Future<?> future = exec.submit(new Runnable() {
    public void run() {
      String key = entry.getKey();
      CustomClass value = entry.getValue();
      value.tick(key);
    }
  });
  futures.add(future);
}

// wait for each future to complete before moving on
for (final Future<?> future : futures) {
  try {
    future.get();
  } catch (Execption e) {
    e.printStackTrace();
  }
}

我强烈建议您同时以多线程和单线程方式运行代码。除非value.tick 需要非常 很长时间，否则在一个线程中执行此操作可能会更快；每当运行多线程代码时，Java 必须做很多无形的开销工作，以确保不会以不一致的方式访问内存。