任务执行器vs Java 8并行流

Question

我找不到关于我们被要求进行的调查的具体答案

我看到并行流在使用少量线程时性能可能不是那么好，而且当DB在处理当前请求的同时阻止下一个请求时，它的表现显然也不是那么好

然而,我发现实现任务执行器与并行流的开销是巨大的,我们实现了一个POC,它只需要这一行代码就能满足并发需求：

List<Map<String, String>> listWithAllMaps = mappedValues.entrySet().parallelStream().map(e -> callPlugins(e))
        .collect(Collectors.toList());

而在Task Executor中，我们需要重写Runnable接口并编写一些繁琐的代码，以使Runnable不是空的，并返回我们从DB中读取的值，从而导致我们花费几个小时（如果不是几天）的编码时间，生成一个可维护性较差、更容易出现bug的代码

然而，我们的CTO仍然不愿意使用并行流，因为将来可能会出现不可预见的问题

所以问题是，在一个环境中，我需要对一个数据库进行几个并发只读查询，对每个查询使用不同的Java组件/REST调用：在任何方面，使用任务执行器而不是并行流是否更可取，如果是，为什么？

Answer 1

使用TaskExecutor作为CompletableFuture的执行器。

List<CompletableFuture> futures = mappedValues.entrySet().stream().map(e - > CompletableFuture.supplyAsync(() -> callPlugins(e), taskExecutor)).collect(Collectors.toList());

List<Map<String, String>> listWithAllMaps = futures.stream().map(CompletableFuture::join).collect(Collectors.toList());

不知道这有多麻烦。是的，这是多了一些代码，但优点是您可以轻松地配置TaskExecutor并增加线程数、队列大小等。

免责声明：我是从头顶打出来的，所以一些小东西可能与代码片段有关。