<dependency> <groupId>javax.servlet</groupId> <artifactId>javax.servlet-api</artifactId> <version>3.1.0</version> <scope>provided</scope> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>4.2.3.RELEASE</version> </dependency>
@RequestMapping(value="/asynctask", method = RequestMethod.GET)
public DeferredResult<ModelAndView> asyncTask(){
DeferredResult<ModelAndView> deferredResult = new DeferredResult<ModelAndView>();
System.out.println("/asynctask 调用!thread id is : " + Thread.currentThread().getId());
longTimeAsyncCallService.makeRemoteCallAndUnknownWhenFinish(new LongTermTaskCallback() {
@Override
public void callback(Object result) {
System.out.println("异步调用执行完成, thread id is : " + Thread.currentThread().getId());
ModelAndView mav = new ModelAndView("remotecalltask");
mav.addObject("result", result);
deferredResult.setResult(mav);
}
});
}
public interface LongTermTaskCallback {
void callback(Object result);
}
public class LongTimeAsyncCallService {
private final int CorePoolSize = 4;
private final int NeedSeconds = 3;
private Random random = new Random();
private ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(CorePoolSize);
public void makeRemoteCallAndUnknownWhenFinish(LongTermTaskCallback callback){
System.out.println("完成此任务需要 : " + NeedSeconds + " 秒");
scheduler.schedule(new Runnable() {
@Override
public void run() {
callback.callback("长时间异步调用完成.");
}
}, "这是处理结果:)", TimeUnit.SECONDS);
}
}
@RequestMapping(value="/longtimetask", method = RequestMethod.GET)
public WebAsyncTask longTimeTask(){
System.out.println("/longtimetask被调用 thread id is : " + Thread.currentThread().getId());
Callable<ModelAndView> callable = new Callable<ModelAndView>() {
public ModelAndView call() throws Exception {
Thread.sleep(3000); //假设是一些长时间任务
ModelAndView mav = new ModelAndView("longtimetask");
mav.addObject("result", "执行成功");
System.out.println("执行成功 thread id is : " + Thread.currentThread().getId());
return mav;
}
};
return new WebAsyncTask(callable);
}
@RequestMapping(value="/longtimetask", method = RequestMethod.GET)
public WebAsyncTask longTimeTask(){
System.out.println("/longtimetask被调用 thread id is : " + Thread.currentThread().getId());
Callable<ModelAndView> callable = new Callable<ModelAndView>() {
public ModelAndView call() throws Exception {
Thread.sleep(3000); //假设是一些长时间任务
ModelAndView mav = new ModelAndView("longtimetask");
mav.addObject("result", "执行成功");
System.out.println("执行成功 thread id is : " + Thread.currentThread().getId());
return mav;
}
};
WebAsyncTask asyncTask = new WebAsyncTask(2000, callable);
asyncTask.onTimeout(
new Callable<ModelAndView>() {
public ModelAndView call() throws Exception {
ModelAndView mav = new ModelAndView("longtimetask");
mav.addObject("result", "执行超时");
System.out.println("执行超时 thread id is :" + Thread.currentThread().getId());
return mav;
}
}
);
return new WebAsyncTask(3000, callable);
}
@RequestMapping(value = "/asynctask", method = RequestMethod.GET)
public DeferredResult<ModelAndView> asyncTask() {
DeferredResult<ModelAndView> deferredResult = new DeferredResult<ModelAndView>(2000L);
System.out.println("/asynctask 调用!thread id is : " + Thread.currentThread().getId());
longTimeAsyncCallService.makeRemoteCallAndUnknownWhenFinish(new LongTermTaskCallback() {
@Override
public void callback(Object result) {
System.out.println("异步调用执行完成, thread id is : " + Thread.currentThread().getId());
ModelAndView mav = new ModelAndView("remotecalltask");
mav.addObject("result", result);
deferredResult.setResult(mav);
}
});
deferredResult.onTimeout(new Runnable() {
@Override
public void run() {
System.out.println("异步调用执行超时!thread id is : " + Thread.currentThread().getId());
ModelAndView mav = new ModelAndView("remotecalltask");
mav.addObject("result", "异步调用执行超时");
deferredResult.setResult(mav);
}
});
return deferredResult;
}
@ExceptionHandler(Exception.class)
public ModelAndView handleAllException(Exception ex) {
ModelAndView model = new ModelAndView("error");
model.addObject("result", ex.getMessage());
return model;
}
机械节能产品生产企业官网模板...
大气智能家居家具装修装饰类企业通用网站模板...
礼品公司网站模板
宽屏简约大气婚纱摄影影楼模板...
蓝白WAP手机综合医院类整站源码(独立后台)...苏ICP备2024110244号-2 苏公网安备32050702011978号 增值电信业务经营许可证编号:苏B2-20251499 | Copyright 2018 - 2025 源码网商城 (www.ymwmall.com) 版权所有