Java 如何使线程超时

Java 如何使线程超时

的确使用

ExecutorService

而不是来代替

Timer

，这是SSCCE：

package com.stackoverflow.q2275443;import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;import java.util.concurrent.TimeUnit;import java.util.concurrent.TimeoutException;public class Test {    public static void main(String[] args) throws Exception {        ExecutorService executor = Executors.newSingleThreadExecutor();        Future<String> future = executor.submit(new Task());        try { System.out.println("Started.."); System.out.println(future.get(3, TimeUnit.SECONDS)); System.out.println("Finished!");        } catch (TimeoutException e) { future.cancel(true); System.out.println("Terminated!");        }        executor.shutdownNow();    }}class Task implements Callable<String> {    @Override    public String call() throws Exception {        Thread.sleep(4000); // Just to demo a long running task of 4 seconds.        return "Ready!";    }}

timeout

在

Future#get()

方法中使用参数，例如将其增加到5，你将看到线程完成。你可以在catch

(TimeoutException e)

块中拦截超时。

更新：澄清一个概念的误解，将

sleep()

是不必需的。它仅用于SSCCE /演示目的。只要做你的长时间运行的任务就在那里发生的

sleep()

。在长时间运行的任务中，应检查线程是否未中断，如下所示：

while (!Thread.interrupted()) {    // Do your long running task here.}