java使用异步CompletableFuture 进行计算

简单记录下，后面有时间 详细研究，

 

// 开启并行计算
List collect = dataList.getInnerOrganizations().stream()
        .map(innerOrg -> createTaskSupplier(context, innerOrg))
        .collect(Collectors.toList())
        .stream()
        .map(CompletableFuture::join)
        .collect(Collectors.toList());

logger.info("并行计算数量：{}", collect.size());

 

private CompletableFuture createTaskSupplier(OpenCategoryListContext context, Organization organization) {
	return CompletableFuture.runAsync(
			() -> do(context), "自定义线程池");
}

// 构建线程池
int processors = Runtime.getRuntime().availableProcessors();
final ForkJoinPool forkJoinPool = new ForkJoinPool(processors);