java 开启异步 异步注解 @Async
需要配合启动类注解 @EnableAsync 使用
-
注意:异步的调用方法跟被调用方法不能在同一个类 中,否则会不生效 如果异步方法有返回值,此时获取的方法返回值则会为null。 解决方法:将返回值作为参数,传入方法中,并将方法的返回值改为void
- 调用异步方法
public Result statistics(@RequestBody ModularTimeParam param) throws Exception { long startTime = System.currentTimeMillis(); // 设置线程锁,多少个子线程,后面的数字就写几 final CountDownLatch latch = new CountDownLatch(7); Map<String,Map<String,Object>> listMap = new HashMap<>(); // 子线程 Map<String,Object> htmlTest = new HashMap<>(); controller.htmlTest(param.getProId(),latch,htmlTest); // 主线程 等待线程执行完毕(为0则为执行完毕) latch.await(); listMap.put("htmlTest",htmlTest); System.out.println("总耗时:"+(System.currentTimeMillis() - startTime)+" 毫秒"); return Result.ok("arrange",listMap); }
- 异步方法
@Async public void htmlTest(int id, CountDownLatch latch,Map<String, Object> map){ map.put("status",flag); latch.countDown(); }
上一篇:
通过多线程提高代码的执行效率例子