1 
public class TestThreadTerminate {
    public static void main(String args[]) throws Exception {
        ExecutorService e = Executors.newCachedThreadPool();
        Future<Boolean> f = e.submit(new Callable<Boolean>() {
            @Override
            public Boolean call() throws Exception {
                System.out.println("Step 1!!");
                Thread.sleep(5000);
                System.out.println("Step 2!!");
                Thread.sleep(5000);
                System.out.println("Step 3!!");
                return true;
            }
        });
        try {
            Boolean flag = f.get(1, TimeUnit.SECONDS);
        } catch(TimeoutException ex) {
            f.cancel(true);
            System.out.println("Canceling");
        }
        System.out.println("FINAL!");
    }
}

有了这个，我的输出是

Step 1
Canceling
Final

但是程序会在很久以后终止。为什么一旦线程中断就会发生？

如果我删除f.cancel(true)，我的线程会继续运行并打印以下内容：

Step 1
Canceling
Final
Step 2
Step 3

我能做些什么来终止程序，即终止内线程？实际上，我想将此线程用于线程池中的其他任务，这似乎不会在这里发生。

在返回之前放置Thread.currentThread().isInterrupted()所有地方看起来不是一个好主意。

4

1 回答 1

2

为什么一旦线程中断就会发生？

这是因为您的线程池仍然处于活动状态 - 它可能会接受另一个要执行的可运行/可调用的，因此它会在清理池中未使用的线程之前等待查看是否发生这种情况。

缓存线程池的默认超时时间是 60 秒 - 这与您所看到的相符吗？

如果您希望它更快地关闭，您应该调用e.shutdown().

于 2015-04-16T01:49:41.433 回答