Java：强制停止 ExecutorService 线程

Question

我的代码：

String[] torrentFiles = new File("/root/torrents/").list();

        if(torrentFiles.length == 0 || torrentFiles == null)
        {
            System.exit(0);
        }

        ex = Executors.newFixedThreadPool(3);

        for(String torrentFile : torrentFiles)
        {
            ex.submit(new DownloadTorrent("/root/torrents/" + torrentFile));
        }

        ex.shutdown();

        try
        {
            ex.awaitTermination(30, TimeUnit.MINUTES);
        }
        catch(InterruptedException ex1)
        {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex1);
        }

但有时 torrent 下载需要未知的时间值，并且 «awaitTermination» 无法按我想要的方式工作。我需要在半小时后立即停止所有已执行的线程，但据我所知，“awaitTermination”仅使用仅在循环或等待中工作的“interrupt()”方法。所以如果这一刻发生，超时就不起作用。那么，如何做呢？

Answer 1

永远不能保证线程立即终止，除非线程定期检查 isInterrupted() 标志（或者在可中断方法中等待，即抛出 InterruptedException）。

当工作线程定期检查 isInterrupted() 时，请考虑以某种方式实现工作线程。这可能是这样的：

public void run() { 
  byte[] data;
  do {
     data = receiveDataChunk(timeout);
     processData(data);
  } while(!isInterrupted() && data != null);
}

Answer 2

ExecutorService.shutdownNow() 将尝试停止所有正在执行的线程。

这是 javadoc 的引用

列表<可运行> shutdownNow()

尝试主动阻止一切
执行任务，停止处理
等待任务的数量，并返回一个列表
正在等待的任务
执行。

没有任何保证
超出尽力阻止的范围
处理主动执行的任务。
例如，典型的实现
将通过 Thread.interrupt() 取消，所以
如果有任何任务被屏蔽或无法响应
打扰，他们可能永远不会
终止。

Answer 3

由于下载 torrent 可能涉及阻塞 IO 操作，因此仅调用 cancel()/shutdownNow() 是不够的，因为阻塞 IO 操作不能保证在其终止时终止。相应的线程被中断。

您还需要关闭底层套接字以取消阻塞 IO，请参阅 如何立即终止阻塞在套接字IO操作上的线程？。

Answer 4

< code>ExecutorService.submit(...) 返回一个具有 cancel() 方法的 Future。您应该跟踪这些可以在您希望每个任务停止时调用它。

Answer 5

正在使用我创建的这段代码。

它使用 wkhtmltopdf 从许多 html 模板生成许多 pdf 文件。

所以我想提高创建手红的性能而不让客户等待，这只是实现的一部分。

关于 getListOfCallables 它返回正确的最优值
创建固定池时使用的线程数阈值。

所以我无法处理周围有很多未死的线程，这使得我的 EC2
CPU 100% 卡住。

使用了：

• shutdown()
• shutdownNow() in else of wait
• 我在异常部分中

shutdownNow()列表 fileGenerationHtmlToPdfList = getListOfCallables(paths, name, options);

            ExecutorService executorService = Executors.newFixedThreadPool(fileGenerationHtmlToPdfList.size());


            List<Future<ArrayList<File>>> futures = null;

            try {
                futures = executorService.invokeAll(fileGenerationHtmlToPdfList);
                try {
                    for(Future f: futures) {
                        files.addAll((ArrayList<File>)f.get());
                    }

                } catch (InterruptedException ex) {
                    Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex);
                } catch (ExecutionException ex) {
                    Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex);
                }
            } catch (InterruptedException ex) {
                Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex);
            }

 executorService.shutdown();//try shutdown

            try {
                if (executorService.awaitTermination(5, TimeUnit.SECONDS)) {
                    Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Done ShutDowned");
                } else {
                    executorService.shutdownNow();
                }
            } catch (InterruptedException ex) {
                executorService.shutdownNow();
                Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex);
            }

Answer 6

现在我必须停止池中的线程。我就是这样做的。这可能不是一个好主意。如果有的话请评论一下。

boolean isTerminated = mPoolThreads.isTerminated();
while (!isTerminated) {
    mPoolThreads.shutdownNow();
    isTerminated = mPoolThreads.isTerminated();
    Log.i(Constants.LOG_TAG, "Stop threads: the threads are not terminated yet");
}
Log.w(Constants.LOG_TAG, "Stop threads: Terminated");