使用线程池小于任务的 ExecutorService

Question

我对 ExecutorService 有疑问。 我有Status 的列表，每个状态都包含具有此状态的人员列表。我想做的是

1. 检索状态列表
2. 我想同时处理所有处于 S 状态的人。
3. 状态 S 的处理完成后，我想以相同的方式处理状态 S1，直到处理完所有状态
4. 返回所有已处理的人

我有这个代码

ExecutorService threadExecutor = Executors.newFixedThreadPool(10);
List<Status> statusList = getStatusList();
List<PersonInfoWrapper> personInfoWrapperList = new ArrayList<>();

for(Status status: statusList ){
    List<PersonInfo> personInfo = status.getPersonList();
    List<Future<PersonInfoWrapper> futures = new ArrayList<>();

    for(PersonInfo info : personInfo){
         Future<PersonInfoWrapper> future = threadExecutor.submit(() -> processInfo(info));
         futures.add(future);
    }

    for(Future<PersonInfoWrapper> future : futures ){
         personInfoWrapperList .add(future.get());
    }
}
threadExecutor.shutdown();

我的问题是：

1. ExecutorService 有 10 个线程池。但是每个状态的人数都超过 10 个。当我同时处理它时（如第二个for循环所示），然后在第三个for循环中调用future.get（），它不会阻塞ExecutorService中其他任务的执行吗？

2. 这样重用ExecutorService可以吗？我不应该为即将处理的每个状态都使用新的执行器服务吗？

Answer 1

1. 我建议你使用 Executors.newCachedThreadPool()，所以如果你有更多的人，那么线程这个投票将根据需要自动创建新线程，并在它们可用时重用以前构造的线程。如果没有可用的现有线程，将创建一个新线程并将其添加到池中。六十秒内未使用的线程将被终止并从缓存中删除。因此，闲置时间足够长的池不会消耗任何资源。

Future 为您提供 isDone() 方法，它不会阻塞，如果计算完成则返回 true，否则返回 false。

Future.get() 用于检索计算结果。

你有几个选择：

• 调用 isDone()，如果结果准备就绪，通过调用 get() 请求它，注意没有阻塞
• 用 get() 无限期阻塞
• 用get(long timeout, TimeUnit unit)阻塞指定超时

1. 创建多个 executorService 实例是个坏主意。因此，是的，您应该重复使用现有的。

希望，这会有所帮助。