ExecutorService 对单个线程的时间限制

Question

我有一个 ExecutorService 管理许多 Callables。 Callables 运行的任务主要是黑盒转换和数字运算。在某些情况下，正在转换的数据会振荡，线程将需要一个多小时才能完成。相比之下，大多数线程在一分钟内完成。

已确定来自长时间运行的线程的数据不相关。我想中断任何运行时间超过一定时间的线程。最好的方法是什么？

Answer 1

使用 ScheduleExecutorService 在达到超时时将任务安排到 taskFuture.cancel(true) 长时间运行的任务。如果任务在此之前完成，则不会被取消。

ExecutorService service = Executors.newFixedThreadPool(N);
ScheduledExecutorService canceller = Executors.newSingleThreadScheduledExecutor();

public <T> Future<T> executeTask(Callable<T> c, long timeoutMS){
   final Future<T> future = service.submit(c);
   canceller.schedule(new Callable<Void>(){
       public Void call(){
          future.cancel(true);
          return null;
       }
    }, timeoutMS, TimeUnit.MILLI_SECONDS);
   return future;
}

Answer 2

您可以像其他答案中那样取消未来等，但您需要确保“数字运算”的线程可以处理中断并优雅地终止。你说这是一个黑匣子操作 - 你有多确定线程的中断状态正在黑匣子内被主动检查？如果不是，则无法通过中断取消它。编写黑匣子时需要考虑到中断。

Answer 3

做到这一点的最佳方法是再引入一个 Executor。您可以使用 ScheduledExecutorService 取消所有长时间运行的任务，例如：

ExecutorService service = Executors.newFixedThreadPool(N);

ScheduledExecutorService canceller = Executors.newScheduledThreadPool(1);

public void executeTask(Callable<?> c){
   final Future<?> future = service.submit(c);
   canceller.schedule(new Runnable(){
       public void run(){
          future.cancel(true);
       }
    }, SECONDS_UNTIL_TIMEOUT, TimeUnit.SECONDS);
}

Answer 4

您可以获得相应 Futures 的列表（在您提交 Callable 时创建）及其启动时间。

然后，另一个任务可以每分钟检查是否有某个任务运行超过定义的时间，如果是，则在 Future 中调用 cancel(true) 。已完成的期货将从清单中删除。

Answer 5

您可以使用此方法

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                              long timeout,
                              TimeUnit unit)
                          throws InterruptedException

并将最大超时设置为一分钟。如果你的线程花费的时间超过这个时间，它就会被中止。

Answer 6

问题是你不能杀死/停止/挂起java线程。
全部已弃用。

future.cancel 只会在工作线程之前考虑，

因此如果线程被任何代码执行卡住并且没有考虑线程中断的逻辑，那么执行仍然会继续。

对于 executorService.shutdown(); 来说更是如此。

文档说。

除了尽力尝试停止处理之外，没有任何保证
积极执行任务。例如，典型的实现将
通过线程取消。中断，因此任何未能响应的任务
中断可能永远不会终止。

因此，唯一的解决方案是记录这种情况并解决固有问题。

    Future<?> future = executor.submit(task);
    try {
        future.get(15, TimeUnit.MINUTES);
    } catch (InterruptedException e) {
        // retry waiting. iterative approach not shown here
    } catch (ExecutionException e) {
        // your task exploded
    } catch (TimeoutException e) {
        // The task is running longer than usual
        // Log it for future analysis

        //If the interrupt signal is handled 
        //OR the task is stuck in the queue itself for a long time
        //then worth calling below 
        future.cancel(true);
    }