Java线程池执行器空闲线程关闭-调用自定义清理代码

Question

根据ThreadPoolExecutor文档（Java ThreadPoolExecutor），如果我像这样创建一个executor服务：

new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);

当#线程

Answer 1

正确的方法是在run（）方法返回后扩展线程并运行清理代码，如下所示：

    BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(50);
    ThreadFactory threadFactory = new ThreadFactory() {
        @Override
        public Thread newThread(Runnable r) {
            return new Thread(r) {
                @Override
                public void run() {
                    super.run();
                    //DO YOUR CLEANUP HERE
                }
            };
        }
    };
    new ThreadPoolExecutor(1, 10, 10, TimeUnit.SECONDS, workQueue, threadFactory);

在您的场景中，中断几乎肯定不会被调用，因为它只会在关闭活动的执行器时被调用（即使如此，也不总是这样）。

通过在运行后直接调用cleanup，在线程死亡之前（runnable的run（）方法返回后线程死亡），将调用清理代码。