java - executor.invokeAll() 没有完成执行

Question

所以我正在尝试在“玩具语言”上实现某种 fork 。这就像实现我自己的编译器。因此，当用户进行 fork 时，我的程序应该启动/模拟一些线程。在我的代码中，我准备了可调用对象，然后开始执行可调用对象，但是当我使用 invokeAll 时，我的程序并没有终止，只是什么也没做。

我通过调试运行代码，当我到达 invokeAll() 时它只是停止调试，但它不会终止或抛出错误或任何东西(我在 try-catch 中调用)。我也尝试过固定线程池。它什么都不做

部分代码:

// preparing the callables
java.util.List<Callable<MyClass>> callList = prgll.stream()
        .map(p -> (Callable<MyClass>) () -> {
    return p.oneStep(); //a method from my class
}).collect(Collectors.toList());

//start the execution of the callables
//it should return the list of new created threads
ExecutorService executor = Executors.newSingleThreadExecutor();
java.util.List<MyClass> fff;
try {
    fff = executor.invokeAll(callList).stream() // here my program gets blocked but not all the time, only when I call use myFork class
    .map(future-> {
        try {
            return future.get();
        } catch (Exception e) {
            e.printStackTrace();
            throw new CustomException("Error in onestepforall" + e.getMessage());
        }
    }).filter(p->p != null).collect(Collectors.toList());

} catch (InterruptedException e) {
    e.printStackTrace();
    throw new CustomException("Error while trying executor" +e.getMessage());
}

我能否调试它以更深入地了解我的代码，以准确了解 invokeAll 保持待命状态的原因？

我也尝试从一个新的 SingleThread 更改为一个固定池，但它仍然没有做任何事情。

Answer 1

invokeAll() 是一种阻塞方法，即它会等待所有 futures 完成。

.map 如果您想要异步任务提交，则通过执行程序的 submit() 调用的列表。

如果您的问题是为什么任务没有完成，那么您不想调试提交给执行程序的线程，而是调试生成的线程，因为任务是在单独的线程上执行的。您可以使用附加的调试器简单地挂起整个 JVM，然后查看各个线程，而不是使用断点。