Java 8并行流中的自定义线程池
Java 8并行流中的自定义线程池
提问于 2014-01-16 13:26:37
是否可以为Java8 平行流指定一个自定义线程池？我哪儿都找不到。
假设我有一个服务器应用程序，我想使用并行流。但是这个应用程序很大，而且是多线程的，所以我想对它进行划分。我不希望在应用程序块任务的一个模块中从另一个模块中缓慢运行任务。
如果我不能对不同的模块使用不同的线程池，这意味着在大多数实际情况下，我不能安全地使用并行流。
尝试下面的示例。有一些CPU密集型任务在单独的线程中执行。这些任务利用并行流。第一个任务中断了，所以每一步都需要1秒(线程睡眠模拟)。问题是其他线程会被卡住，等待坏掉的任务完成。这是一个精心设计的示例，但是假设一个servlet应用程序和一些人向共享的叉连接池提交了一个长期运行的任务。
public class ParallelTest {
public static void main(String[] args) throws InterruptedException {
ExecutorService es = Executors.newCachedThreadPool();
es.execute(() -> runTask(1000)); //incorrect task
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.shutdown();
es.awaitTermination(60, TimeUnit.SECONDS);
}
private static void runTask(int delay) {
range(1, 1_000_000).parallel().filter(ParallelTest::isPrime).peek(i -> Utils.sleep(delay)).max()
.ifPresent(max -> System.out.println(Thread.currentThread() + " " + max));
}
public static boolean isPrime(long n) {
return n > 1 && rangeClosed(2, (long) sqrt(n)).noneMatch(divisor -> n % divisor == 0);
}
}Stack Overflow用户
发布于 2019-02-01 13:51:24
如果您不想依赖于实现hacks，那么通过实现将map和collect语义相结合的自定义收集器，总是有一种方法可以实现同样的目的.而且你不会局限于ForkJoinPool：
list.stream()
.collect(parallel(i -> process(i), executor, 4))
.join()幸运的是，它已经在这里完成，并且可以在Maven Central：http://github.com/pivovarit/parallel-collectors上使用。
免责声明:我写的，并对此负责。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/21163108
复制相关文章
相似问题
腾讯云开发者
