使用多线程异步循环

Question

我有嵌套循环。我知道没有办法减少嵌套循环完成所花费的时间。但是我们如何才能使用多线程或执行器服务更快地完成循环。

例如：

for(String str : ListA){
  for(String str1 : ListB){
     for(String str2 : ListC){
         //do Something
     }
  }
}

所以我知道完成循环需要 MNP（其中 M,N,P 是列表的大小）次。但是我如何在这里利用多线程并通过执行异步作业更快地完成循环。我想像使用 java 7 一样使用 Executor Service（不能使用并行流）。

我试过了：

ExecutorService executor = Executors.newFixedThreadPool(10);
for(String str : ListA){
     executor.execute(new Runnable() {
    @Override
    public void run() {
      for(String str1 : ListB){
        for(String str2 : ListC){
         //do Something
        }
      }
    } });
 }

但我相信上述过程是启动线程 10 次但执行相同的事情 10 次，这不是循环的工作方式。有人可以建议我如何使用 Java 中的多线程执行器服务来完成这个循环吗？

Answer 1

循环足够快，您无需对其进行优化。您在 //do something 中执行的实际代码可能是一个问题，如果它有阻塞行为。在这种情况下，您可以执行以下操作

ExecutorService executor = Executors.newFixedThreadPool(10);

List<String> level1 = Arrays.asList("1", "2", "3");
List<String> level2 = Arrays.asList("a", "b", "c");
List<String> level3 = Arrays.asList("x", "y", "z");
for(String l1 : level1){
  for(String l2 : level2){
     for(String l3 : level3){
        executor.execute(new Runnable() {
            @Override
            public void run() {
                get("http://foo.com/"+l1+"/"+l2+"/"+l3);
            }
        });
     }
  }
}