使用线程池小于任务的ExecutorService

Question

null

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();

Answer 1

1. 我建议您使用executors.newCachedThreadPool（），因此，如果您的人员多于线程，则该轮询将根据需要自动创建新线程，并在以前构造的线程可用时重用它们。如果没有可用的现有线程，将创建一个新线程并将其添加到池中。60秒内未使用的线程将被终止并从缓存中删除。因此，空闲时间足够长的池将不会消耗任何资源。

Future为您提供了不阻塞的方法isDone（），如果计算已经完成，则返回true，否则返回false。

get（）用于检索计算结果。

null