福克斯：泳池和未来。收到

Question

假设我有一个并行度为n的ForkJoinPool设置，我称之为这样的并行计算：

 workpool.submit(
            () -> {
                    objects.values().parallelStream().forEach(obj -> {
                        obj.foo();
                    });
                });

我这样做是为了确保生成的线程是在工作池中创建的（我有需要隔离的系统的不同组件）。现在假设调用它的线程也在这个工作池中执行，我会：

 Future<?> wait =  workpool.submit(
            () -> {
                    objects.values().parallelStream().forEach(obj -> {
                        obj.foo();
                    });
                });
 wait.get()

1） 我是不是挡住了泳池里的一根线？如果我让n个线程都阻塞未来，同时尝试在工作池中安排任务，这会导致死锁吗？我不清楚ForkJoinPool中的“最大并行度”是否意味着（如果有n个未阻塞的任务），将始终有n个线程在执行，或者是否有固定数量的线程，无论是否有阻塞。如果我用等等怎么办。join（）而不是等待。join（我不需要检查异常，因为此代码中抛出的任何异常都将生成runtimeexception。如果我理解正确，join（）将允许线程在等待时执行排队的任务）

2） 如果我通过做（）来创建一个可运行的“包装器”类，那么我是否仍能从并行流的轻量级forkjoin任务中获益-

3）是否有任何缺点/好处使用这个代替（假设。

        CompletableFuture.supplyAsync(this::mylambdafunction, workpool)  
             .thenAccept(this::mynextfunction);

Answer 1

对第1点的回应：如果看不到实际的方法实现，很难知道代码是否会阻塞。处理阻塞代码的一种方法是增加forkjoin线程池中的线程数。通常，forkjoin线程中的线程数为n1，用于计算密集型任务，其中n=处理器数。或者，如果有I/O阻塞，可以使用ManagedBlocker。

对第2点的答复：是的

对第3点的回应：未来完整代码的明显优势在于thenAccept是非阻塞的。因此，控件将立即通过CompletableFuture块进入下一个语句，而无需等待，而在之前使用ForkJoin池编写的代码中，则需要等待。get（）将阻止，直到您获得答案，并且在此之前不会继续。