FutureTask异步任务,超时打断执行


背景: 在做接口对接的时候,对于接口不通的情况。最好设置一个超时时间, 一个小demo记录执行异步方法的方式

 

下图4000是4秒,会导致超时

package com.louis.z.ifs.demo;

import java.util.concurrent.*;

public class Test {
public static void main(String[] args) {
try {
ThreadPoolExecutor pool = (ThreadPoolExecutor) Executors.newFixedThreadPool(1);
FutureTask<Long> futureTask = (FutureTask<Long>) pool.submit(new Callable<Long>() {
@Override
public Long call() throws Exception {
long s = System.currentTimeMillis();
System.out.println("Callable Start");
while (!Thread.currentThread().isInterrupted()) {
if (System.currentTimeMillis() - s > 4000) {
System.out.println("Callable break;");
break;
}
}
System.out.println("Callable Over");
return System.currentTimeMillis() - s;
}
});
try {
Long r = futureTask.get(3, TimeUnit.SECONDS);
System.out.println("用时:" + r);
} catch (InterruptedException | ExecutionException | TimeoutException e) {
futureTask.cancel(true);
System.out.println("futureTask cancel");
} finally {
pool.shutdown();
System.out.println("finally");
}
} catch (Exception e) {
e.printStackTrace();
}
}
}

结果如下

 

 ,如果时间改为2000.效果如下。

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM