将ExecutorService与任务树结合使用以执行

Question

我们有一个问题。:)

我们要确保任何时候只有N个线程在执行后台任务。为此，我们使用了固定线程池执行程序。它似乎工作正常。

然后我们发现了一个问题。假设您有一个使用执行程序执行一些并行工作的类，然后在执行程序线程中调用了另一个类，该线程也执行一些并行工作，打算等待它。这是发生了什么：

• 主线程调用第一级方法。
• 这种方法认为它可以并行化为16个任务，并拆分其工作。
• 16个任务被提交给执行者。
• 主线程开始等待其任务完成。
• 假设有四个线程可用，则每个前四个任务都会被拾取并运行。因此，队列中还有12个任务。
• 现在，这些任务之一调用了其他方法。
• 这种新方法认为它可以并行化为2个任务。假设这是并行合并排序中的第一步，或者类似的东西。
• 2个任务被提交给执行者。
• 现在，该线程开始等待其任务完成。

哦哦 因此，此时，所有四个线程将等待任务完成，但是它们正在协作阻止实际执行这些任务的执行程序。

此问题的解决方案1如下：在向执行程序提交新任务时，如果我们已经在运行所有线程，并且已经在其中一个执行程序线程上运行，则内联运行任务。这可以正常工作10个月，但是现在我们遇到了问题。如果它正在提交的新任务还比较大，那么您可能会遇到新任务阻止该方法将其他任务添加到队列的情况，否则其他线程就可以将其拾取。因此，在线程内联处理工作时，您会遇到巨大的延迟。

有没有更好的解决方案来解决执行潜在无限制的后台任务树这一核心问题？我知道，.NET相当于执行程序服务，具有某种内置的从队列中窃取的功能，可以防止发生原始的死锁问题，据我所知，这是一个理想的解决方案。但是在Java领域呢？

Answer 1

Java
7的概念ForkJoinPool允许任务通过将任务提交给同一执行者来“分叉”另一个任务。然后为它提供一个选项，供以后尝试通过尝试运行“帮助加入”该任务（如果尚未运行）的选项提供。

我相信，通过简单地将Executorwith与组合，可以在Java 6中完成相同的操作FutureTask。像这样：

public class Fib implements Callable<Integer> {
    int n;
    Executor exec;

    Fib(final int n, final Executor exec) {
        this.n = n;
        this.exec = exec;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public Integer call() throws Exception {
        if (n == 0 || n == 1) {
            return n;
        }

        //Divide the problem
        final Fib n1 = new Fib(n - 1, exec);
        final Fib n2 = new Fib(n - 2, exec);

        //FutureTask only allows run to complete once
        final FutureTask<Integer> n2Task = new FutureTask<Integer>(n2);
        //Ask the Executor for help
        exec.execute(n2Task);

        //Do half the work ourselves
        final int partialResult = n1.call();

        //Do the other half of the work if the Executor hasn't
        n2Task.run();

        //Return the combined result
        return partialResult + n2Task.get();
    }

}