java - 为什么我的线程在失败时不会超时？

Question

所以我刚才问了一个问题:Over here问了一个问题“如果我的线程花费的时间太长，我怎样才能让它们被杀死”

我已经实现了那里提到的解决方案，但在线程超时的某些罕见情况下，程序仍然会失败/锁定(请参阅:保持 main() 方法打开，并防止程序的进一步 cron 运行)。

这是我使用的来源:

 //Iterate through the array to submit them into individual running threads.
    ExecutorService threadPool = Executors.newFixedThreadPool(12);
    List<Future<?>> taskList = new ArrayList<Future<?>>();
    for (int i = 0; i < objectArray.length; i++) {
        Future<?> task = threadPool.submit(new ThreadHandler(objectArray[i], i));
        taskList.add(task);
        Thread.sleep(500);
    }

    //Event handler to kill any threads that are running for more than 30 seconds (most threads should only need .25 - 1 second to complete.
    for(Future future : taskList){
        try{
            future.get(30, TimeUnit.SECONDS);
        }catch(CancellationException cx){ System.err.println("Cancellation Exception: "); cx.printStackTrace();
        }catch(ExecutionException ex){ System.err.println("Execution Exception: ");ex.printStackTrace();
        }catch(InterruptedException ix){ System.err.println("Interrupted Exception: ");ix.printStackTrace();
        }catch(TimeoutException ex) {future.cancel(true);}
    }
    threadPool.shutdown();
    threadPool.awaitTermination(60, TimeUnit.SECONDS);

所以我的问题是:执行此代码后，为什么执行程序服务不会在 30 秒时停止运行。

Answer 1

因为我怀疑您的工作线程仍在运行。您正在调用 future.cancel(true); 但所做的只是在线程上设置中断标志——它不会主动中断您正在运行的代码。 “中断”代码的另一种方法是将一些 volatile boolean shutdown 标志设置为 true 并在您的代码中对其进行测试。在这里查看 more details about interrupting threads .

您需要确保您的ThreadHandler 代码能够正确处理中断。例如，它需要在循环或其他代码块中检查 Thread.currentThread().isInterrupted()。您还需要确保您正在正确处理 InterruptedException 而不仅仅是吞下中断。

参见 my answer here有关线程中断的更多信息。