等待执行器中的所有线程完成？

Question

我正在实现并行快速排序作为编程实践，完成后，我阅读了 Executors 上的 Java 教程页面，这听起来像是它们可以使我的代码更快。不幸的是，我依靠 join() 来确保程序在所有内容都排序完成之前不会继续。现在我正在使用：

public static void quicksort(double[] a, int left, int right) {
    if (right <= left) return;
    int i = partition(a, left, right);

    // threads is an AtomicInteger I'm using to make sure I don't
    // spawn a billion threads.
    if(threads.get() < 5){

        // ThreadSort's run method just calls quicksort()
        Future leftThread = e.submit(new ThreadSort(a, left, i-1));
        Future rightThread = e.submit(new ThreadSort(a, i+1, right));

        threads.getAndAdd(2);
        try {
            leftThread.get();
            rightThread.get();
        }
        catch (InterruptedException ex) {}
        catch (ExecutionException ex) {}
    }
    else{
        quicksort(a, left, i-1);
        quicksort(a, i+1, right);
    }
}

这似乎工作正常，但是如果我在调用非递归quicksort()方法后立即运行e.shutdown()，它会出现一堆RejectedExecutionExceptions，所以我认为这不起作用以及我想要的。

所以无论如何，我基本上试图获得与 leftThread.join() 相同的功能，但使用执行器，我的问题是：

这是等待所有线程完成的最佳方法吗？

编辑：好的，所以我弄清楚为什么在关闭执行器后出现一堆错误，这是因为我在循环中调用这个函数（以平衡运行时间）而不是创建一个新的执行器。

Answer 1

您使用什么类型的执行器？

ThreadPoolExecutor< /a>.awaitTermination() 将执行您所询问的操作（这实际上是批量连接操作）。

总而言之，ThreadPoolExecutor 将允许您设置线程数量的限制等...（如果线程计数变高，可能比像您所做的那样递归更好，不确定）。

PS - 我怀疑执行器会让你的代码运行得更快，但它们可能会让你的代码更容易阅读和维护。使用线程池将使此类算法的速度更快，并且执行器可以轻松使用线程池。

Answer 2

看一下 Executors.newFixedThreadPool 它允许您创建最多 n 个线程的池（摆脱“if”）和 ExecutorService.shutdown 方法和 ExecutorsService.awaitTermination 方法。

Answer 3

您可以使用 CountDownLatch

Answer 4

PS - 我怀疑执行器会让你的代码运行得更快，但是
它们可以使您的代码更易于阅读和维护。使用线程
池将使这种算法的速度更快，并且
Executor 可以轻松使用线程池。

这是不正确的。

执行器可以由任意数量的不同执行系统（包括池线程）“支持”。

您需要正确调用工厂类。

此外，您还需要决定处理作业提交到队列的速度快于消耗速度的情况的策略，因为由于线程执行的限制，您最初可能不会耗尽内存，但是如果您对数百万个作业进行排队，那么它们在等待执行时必须存储在某个地方。