java - 中断需要数小时的 Runnable

Question

我有一个线程池执行器:

ThreadPoolExecutor service = new ThreadPoolExecutor(N_THREADS, N_THREADS, 0L, TimeUnit.MILLISECONDS, blockingQueue, rejectedExecutionHandler);

服务执行实现了 Runnable 接口(interface)的线程。每个线程处理磁盘上的一个文件。我发现几个小时后，有两个线程(或内核，取决于 htop 在 Linux 中显示的内容)正在运行，并且已经运行了 13 个小时。更糟糕的是，其余核心没有任何 Activity ，就好像它们在等待两个线程完成一样。

问题:1 - 我已经阅读了很多有关如何解决此问题的信息，但没有定论。据我所知，您不能使用 ThreadPoolExecutor 停止 Runnable，因为它是一个独立的线程，只会运行。使用 Future 框架:

Future<?> f = f.get(submittedtask,XX)

允许您设置超时并获取 future 的结果，但 get 会阻止所有线程有效地使实现串行化。是否可以使用 threadpoolexecutor 在给定时间后中断 Runnable，将线程返回到池中，以便它可以拾取新任务并继续。

2 - 我最担心的是，为什么使用 htop，我看到有两个线程/核心在运行，而没有其他核心/线程在运行，尽管许多任务仍在等待执行(即还有许多文件需要处理)。有什么见解吗？

Answer 1

您可以创建第二个计划线程池，您可以为每个返回的 Future 提交取消任务。在给定超时后，这些任务中的每一个都会检查它的关联 Future 是否已完成，如果没有，则取消它。取消会触发线程中断，因此您可能需要通过检查中断标志在您的任务中支持它:Thread.interrupted()。

第二个线程池的大小可以是最小的，即 1，因为此作业占用的 CPU 时间最少。

代码示例:

ScheduledExecutorService service = Executors.newScheduledThreadPool(1);

...

while(...){
    final Future<?> f = pool.submit(...);

    service.schedule(new Runnable() {
        @Override
        public void run() {
            if(!f.isDone()){
                f.cancel(true);
            }
        }
    }, 1, TimeUnit.MINUTES);
}

service.awaitTermination(1, TimeUnit.MINUTES);
service.shutdown();