这里使用JDK5+的java.util.concurrent包下的API实现，采用这种方式是相对比较安全的。
实现效果：
启动一个任务，然后等待任务的计算结果同时设定一个超时时间，如果等待时间超出预设定的超时时间，则中止任务。
代码实现：
- import java.util.concurrent.Callable;
- import java.util.concurrent.ExecutionException;
- 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 TaskTimeoutDemo {
-
- public static void main(String[] args) {
- System.out.println("Start ...");
-
- ExecutorService exec = Executors.newCachedThreadPool();
-
- testTask(exec, 15);
- testTask(exec, 5);
-
- exec.shutdown();
- System.out.println("End!");
- }
-
- public static void testTask(ExecutorService exec, int timeout) {
- MyTask task = new MyTask();
- Future<Boolean> future = exec.submit(task);
- Boolean taskResult = null;
- String failReason = null;
- try {
-
- taskResult = future.get(timeout, TimeUnit.SECONDS);
- } catch (InterruptedException e) {
- failReason = "主线程在等待计算结果时被中断！";
- } catch (ExecutionException e) {
- failReason = "主线程等待计算结果，但计算抛出异常！";
- } catch (TimeoutException e) {
- failReason = "主线程等待计算结果超时，因此中断任务线程！";
- exec.shutdownNow();
- }
-
- System.out.println("\ntaskResult : " + taskResult);
- System.out.println("failReason : " + failReason);
- }
- }
-
- class MyTask implements Callable<Boolean> {
-
- @Override
- public Boolean call() throws Exception {
-
- for (int i = 0; i < 100L; i++) {
- Thread.sleep(100);
- System.out.print('-');
- }
- return Boolean.TRUE;
- }
- }
|
运行结果：
- Start ...
- ----------------------------------------------------------------------------------------------------
- taskResult : true
- failReason : null
- ---------------------------------------------
- taskResult : null
- failReason : 主线程等待计算结果超时，因此中断任务线程！
- End!
|
