可运行线程在执行后未被销毁

Question

我的代码库很大，所以我会尽量简洁地把它放在这里。

我的假设是，如果Runnable在Thread内完成执行，那么Thread和Runnable都将被销毁，因为Runnable中的代码是线性代码，好吧，也许是一些函数调用，但绝对没有循环。

问题是Thread确实仍在运行，而我认为它不应该运行。

创建RunnableProcessor：

Controller.getInstance().getNamedThreadFactory().addThreadName("EST: " + runnableProcessor.toString());
Controller.getInstance().getExecutorService().execute(runnableProcessor);

RunnableProcessor类：

public class RunnableProcessor<T> implements Runnable {
    private final Processor<T> processor;
    private final T object;
    public RunnableProcessor(final Processor<T> processor, final T object) {
        this.processor = processor;
        this.object = object;
    }
    @Override
    public void run() {
        processor.process(object);
    }
    @Override
    public String toString() {
        return "RunnableProcessor("" + processor + "", "" + object.toString() + "")";
    }
}

这种Processor的一个例子，即InputProcessor：

public class InputProcessor implements Processor<File> {
    private static final String PDF = "pdf";
    @Override
    public void process(File file) {
        if (new CustomPath(file).getExtension().equalsIgnoreCase(PDF)) {
            processPdf(file);
        }
        else {
            processImage(file);
        }
    }
    private void processPdf(final File file) {
        System.out.println("Processing " + file.toString());
        FileEditor.convert(file);
        Utils.move(file.toPath(), new File(Controller.DONE_URL + File.separator + file.getName()).toPath());
        System.out.println("Processed");
    }
    private void processImage(final File file) {
        //Skew detection
        System.out.println("Rotating " + file.toString());
        SkewDetector skewDetector = new SkewDetector(file);
        File rotatedFile = skewDetector.detect();
        Utils.move(rotatedFile.toPath(), new File(Controller.ROTATED_INPUT_URL + File.separator + rotatedFile.getName()).toPath());
        System.out.println("Rotated");
    }
    @Override
    public String toString() {
        return "InputProcessor";
    }
}

代码中没有任何内容阻止执行，也就是说，在这种情况下，特定的字符串Processed或Rotated都被打印到System.out，之后特定的Thread仍然不会死亡。例如，这是其中一个线程仍然处于活动状态，即使Runnable的执行已完成，名称为：EST: RunnableProcessor("InputProcessor", "D:OCRrenamed_input682-converted.tiff") 。

不过，超过两分钟的测量线程的行为似乎很有趣：它遵循以下顺序：快速运行，快速监视，快速运行，非常长的等待，相对短的运行，非常长的等待，

非常长的等待，相对短暂的运行，等待（直到永恒？

谁能帮助弄清楚到底发生了什么？

Answer 1

您似乎正在使用执行程序服务。虽然它可以实现为每个任务创建新线程，但显然在您的情况下，它是使用线程池实现的，该线程池使线程等待新任务运行。根据文档，这样做是为了获得更好的性能。

无论如何，您都不应该依赖于执行程序服务的内部工作原理。如果您需要在任务完成时收到通知，我建议您监视任务或包装器。

如果您想创建一个新的包装器并且似乎正在轮询（线程状态），它可以像以下一样简单：

void run() {
    innerRunner.run();  // the wrapped runner
    doneFlag = true;    // a boolean indicating the status
}

Answer 2

您可能需要调用

Controller.getInstance().getExecutorService().shutdown();
Controller.getInstance().getExecutorService().awaitTermination();

关闭线程池。

Answer 3

使用创建固定数量的线程的线程池。线程池重用创建的线程来执行任务（Runnable, Callable）。不能显式销毁线程，因为线程是可管理的线程池。

正如你@Andrey查舍夫所说，你应该称之为：

Controller.getInstance().getExecutorService().shutdown();
Controller.getInstance().getExecutorService().awaitTermination();

用于线程终止。