为什么我的线程在失败时没有超时？

Question

所以我刚才问了一个问题：在这里问了一个问题"如果我的线程花费太长时间，我怎么能让我的线程被杀死"

我已经实现了那里提到的解决方案，但在某些线程超时的极少数情况下，程序仍然可能失败/锁定（请参阅：保持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，并在代码中对其进行测试。 有关中断线程的更多详细信息，请参阅此处。

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

有关线程中断的更多信息，请参阅此处的答案。

Answer 2

每个任务的超时时间都在增加，这可能不是有意的。 相反，您可以在超时后关闭线程池并取消其余部分。

threadPool.shutdown();
threadPool.awaitTermination(30, TimeUnit.SECONDS);
threadPool.shutdownNow(); // interrupt any running tasks.

Answer 3

在《

Java Concurrency in Practice》一书中有一整章专门介绍任务取消。根据我所读到的内容，任务取消必须在 finally 块中，以确保任务始终结束。

    try{
            future.get(30, TimeUnit.SECONDS);
        } catch (TimeoutException e) {
           // log error message and falls through to finally block
        } catch (ExecutionException e) {
            throw e;
        } finally {
            future.cancel(true); // interrupt task
        }

在

处理中断异常时必须恢复中断状态。

           catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }

在 ThreadHandler 任务中，检查 Thread.currentThread（）.isInterrupted（） 标志，如果为 true，则抛出 InterruptedException 传播中断状态。