@SneakyThrows
private List<ExportEORFinalDetailResDTO> assembleDetailDatas(List<EnterpriseOrder> enterpriseOrders) {
List<ExportEORFinalDetailResDTO> result = Lists.newCopyOnWriteArrayList();
CompletionService completionService = new ExecutorCompletionService(executorService);
List<Future> futures = Lists.newArrayList();
_CollectionUtil.sliceProcess(enterpriseOrders, 50, eors -> {
Future submit = completionService.submit(() -> assembleDetailData(eors));
futures.add(submit);
});
for (Future future : futures) {
Object o = future.get();
if (null != o) {
List<ExportEORFinalDetailResDTO> t = (List<ExportEORFinalDetailResDTO>) o;
result.addAll(t);
}
}
return result;
}