实际上,用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!";
}
}
在Future#get()
方法中稍微使用timeout
参数,例如将其增加到5,您将看到线程结束.你可以在catch (TimeoutException e)
挡路中截取超时.
Update:为了澄清概念上的误解,sleep()
是not.它仅用于SSCCE/演示目的.只需要做your个长时间运行的任务,而不是sleep()
个.在长时间运行的任务中,您应该判 break line 程是否不是interrupted,如下所示:
while (!Thread.interrupted()) {
// Do your long running task here.
}