java - ThreadPoolExecutor 创建的线程在关闭后仍保持运行

Question

我正在尝试使用两个 threadPoolExecutor 应用某些数据的多线程生产者/消费者的原理，我注意到一切正常，但程序拒绝关闭，并且在关闭 2 个 threadPools 后，一些线程仍在运行:

在主类中:

ExecutorService executor = new ThreadPoolExecutor(10, 10, 40, TimeUnit.SECONDS,
        new ArrayBlockingQueue<Runnable>(edmsIds.size()));
ExecutorService consumerExecutor =  new ThreadPoolExecutor(10, 10, 0L, TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(edmsIds.size()));for(
String edmsID:edmsIds)

{

    Runnable worker = new BatchWorkerThread(resumeFile, stratrKeysToUpdate, xslFiles, errorThrown, edmsID,
            consumerExecutor, edmsIds.size(), executor);
    executor.execute(worker);
}

在生产者类别中:

while (edmsNumber > 0) {
    Runnable consumer = new ConsumerThread(brokerWorker);
    consumExecutor.execute(consumer);//decreasing the edmsNumber

}
if (edmsNumber < 1) {
    prodExecutor.shutdownNow();
    consumExecutor.shutdownNow();
}

Answer 1

请参阅doc :

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via Thread.interrupt(), so any task that fails to respond to interrupts may never terminate.

如果正在运行的任务不可中断(不响应中断信号)，则继续执行。