当 Java 中的线程死亡时，ThreadPoolExecutor 会发生什么

Question

我创建了一个线程，该线程又创建一个ThreadPoolExecutor并向它提交一些长时间运行的任务。在某些时候，原始线程由于未处理的异常/错误而死亡。执行程序应该发生什么（它是那个死线程的本地，没有对其的外部引用）？它应该被GCed还是不被GCed？编辑：这个问题从一开始就被错误地表述了，但我会留下它，因为 Gray 提供了一些关于 TPE 如何工作的详细信息。

Answer 1

executor 会发生什么（它是死线程的本地，没有外部引用）？它应该被GCed还是不被GCed？

答案比“是的，如果没有引用它”更复杂。这取决于在 中运行的线程ThreadPoolExecutor是否仍在运行。这又取决于创建的 TPE 类型以及提交给它的“长时间运行的任务”是否已完成。

例如，如果任务尚未完成，则线程仍将运行。即使它们已经完成，如果您的 TPE 具有未设置的核心线程，allowCoreThreadTimeOut(true)那么线程也不会停止。JVM 从不垃圾收集正在运行的线程，因为它们被认为是GC“根”：

...根据定义，正在运行的线程对 GC 免疫。GC 通过扫描“根”开始其工作，这些“根”被认为始终可以访问；根包括全局变量（Java-talk 中的“静态字段”）和所有正在运行的线程的堆栈......

所以下一个问题是线程是否有引用回，ThreadPoolExecutor我相信他们有。内部Worker类是Runnable存储在其中并由它thread.target执行的，Thread因此它不能被GC'd。 Worker并非static如此，它隐含了对外部ThreadPoolExecutor实例的引用。该run()方法实际上是调用ThreadPoolExecutor.runWorker()引用由ThreadPoolExecutor. 因此，正在运行的线程保留对WorkerTPE 和 TPE 的引用，因此垃圾收集器无法收集 TPE。

例如，这是一个引用 TPE 的正在运行的池线程的典型堆栈帧：

java.lang.Thread.sleep(Native Method)

com.j256.GcTester$1.run(GcTesteri.java:15)

java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

java.util.concurrent.FutureTask.run(FutureTask.java:266)

>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

java.lang.Thread.run(Thread.java:748)

但是，如果线程池任务已全部完成并且它有 0 个核心线程或核心线程已超时，那么将没有Worker与ThreadPoolExecutor. 然后 TPE将被垃圾收集，因为除了 GC 足够智能可以检测到的循环引用之外，没有对它的引用。

这是一个演示它的小示例测试程序。finalize()如果有 1 个核心线程，那么即使工作线程在注意到/tmp/x文件存在后退出，TPE 也永远不会关闭（通过）。即使主线程没有引用它也是如此。但是，如果有 0 个核心线程，那么在线程超时后（这里是在完成最后一个任务后 1 秒后）TPE 将被收集。

public class GcTester {

    public static void main(String[] args) {

        int numCore = 1; // set to 0 to have it GC'd once /tmp/x file exists

        ExecutorService pool =

                new ThreadPoolExecutor(numCore, Integer.MAX_VALUE,

                        1, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()) {

                    protected void terminated() {

                        System.out.println(this + " terminated");

                    }

                };

        pool.submit(new Runnable() {

            public void run() {

                while (true) {

                    Thread.sleep(100); // need to handle exception here

                    if (new File("/tmp/x").exists()) {

                        System.out.println("thread exiting");

                        return;

                    }

                }

            }

        });

        pool = null; // allows it to be gc-able

        while (true) {

            Thread.sleep(1000);  // need to handle exception here

            System.gc();         // pull the big GC handle

        }

    }

}

Answer 2

线程就是所谓的GC 根。这意味着无法收集正在运行（或未启动）的线程。这也意味着无法收集从这些线程引用的对象，这就是为什么您可以执行类似的操作new Thread(new MyRunnable()).start()，或者在没有任何引用的情况下运行线程池。

如果线程是一个守护进程，如果所有其他非守护线程都停止了，它可以自动停止。您可以拥有带有守护线程的线程池，但最好的办法是确保正确清理事物（即异常不应终止本应最终停止并清理线程池的线程）。