烟台百度网站排名,什么网站有项目做,健康云下载app,网络运营推广方式有哪些Async概述
Spring中用Async注解标记的方法#xff0c;称为异步方法#xff0c;它会在调用方的当前线程之外的独立的线程中执行#xff0c;
其实就相当于我们自己new Thread(()- System.out.println(hello world !))这样在另一个线程中去执行相应的业务逻辑…Async概述
Spring中用Async注解标记的方法称为异步方法它会在调用方的当前线程之外的独立的线程中执行
其实就相当于我们自己new Thread(()- System.out.println(hello world !))这样在另一个线程中去执行相应的业务逻辑
异步方法实际的执行交给了 Spring 的 TaskExecutor 来完成。
Async使用
Async注解如果用在类的方法上则说明改方法是异步方法Async注解如果用在类上那么这个类所有的方法都是异步执行的Async注解方法的类对象应该是Spring容器管理的bean对象调用异步方法类上需要配置上注解EnableAsync或者是在启动类上加上EnableAsync
Async注意
默认情况下EnableAsync注解的modeAdviceMode.PROXY同一个类内部没有使用Async注解修饰的方法调用Async注解修饰的方法是不会异步执行的如果想实现类内部自调用也可以异步则需要切换EnableAsync注解的modeAdviceMode.ASPECTJ任意参数类型都是支持的但是方法返回值必须是void或者Future类型
Async代码示例
使用1代码实现调用异步方法类上配置EnableAsync
import org.springframework.scheduling.annotation.Async;public interface TestService {Asyncvoid test();
}import com.example.service.TestService;
import org.springframework.stereotype.Service;Service
public class TestServiceImpl implements TestService {Overridepublic void test() {//...}
}调用异步方法的controller类
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.web.bind.annotation.*;RestController
RequestMapping(value /test)
EnableAsync
public class TestContoller {Autowiredprivate TestService testService;GetMapping(value /testAsync)public void print() {testService.test();}
}如果我们去除TestController上的EnableAsync或者new 一个TestService对象该对象没有加载进Spring的容器中那么TestController中的print()方法都会同步执行后台打印日志也可以看到只有一个线程在执行
使用2代码实现在启动类上配置EnableAsync
如果启动类上配置EnableAsync那么在上例代码中便不需要再在Controller上面加上EnableAsync这个注解
入口类增加了 EnableAsync 注解主要是为了扫描范围包下的所有 Async 注解。
注意1代码实现Async没有生效
Async 修饰test()方法test2()方法不修饰
public interface TestService {Asyncvoid test();void test2();
}public class TestServiceImpl implements TestService{Overridepublic void test() {//...}Overridepublic void test2() {test();//自调用test()方法}
}这种情况下“test2()方法调用的test()方法并没有异步执行只有一个线程
AsyncResult
Spring中提供了一个 Future 接口的子类AsyncResult所以我们可以返回 AsyncResult 类型的值。
AsyncResult是异步方式异步主要用于调用的代码需要长时间运行才能返回结果的时候可以不阻塞调用者
public class AsyncResultV implements ListenableFutureV {private final V value;private final ExecutionException executionException;//...
}AsyncResult实现了ListenableFuture接口该对象内部有两个属性返回值和异常信息。
public interface ListenableFutureT extends FutureT {void addCallback(ListenableFutureCallback? super T var1);void addCallback(SuccessCallback? super T var1, FailureCallback var2);
}AsyncResult代码示例
获取异步方法返回值的实现返回String
public FutureString test() throws Exception {log.info(开始做任务);long start System.currentTimeMillis();Thread.sleep(1000);long end System.currentTimeMillis();log.info(完成任务耗时 (end - start) 毫秒);return new AsyncResult(任务完成耗时 (end - start) 毫秒);
}返回自定义类型的话在上面的Future里面的String改为对应的实体类
CompletableFuture
统计一下三个任务并发执行共耗时多少这就需要等到上述三个函数都完成调动之后记录时间并计算结果。
也可以使用CompletableFuture来返回异步调用的结果
通过CompletableFuture.allOf(task1, task2, task3).join()实现三个异步任务都结束之前的阻塞效果三个任务都完成之后根据结束时间 - 开始时间计算出三个任务并发执行的总耗时。
CompletableFuture代码示例
Async
public CompletableFutureString doTaskOne() throws Exception {log.info(开始做任务一);long start System.currentTimeMillis();Thread.sleep(random.nextInt(10000));long end System.currentTimeMillis();log.info(完成任务一耗时 (end - start) 毫秒);return CompletableFuture.completedFuture(任务一完成);
}Test
public void test() throws Exception {long start System.currentTimeMillis();CompletableFutureString task1 asyncTasks.test();CompletableFutureString task2 asyncTasks.test();CompletableFutureString task3 asyncTasks.test();CompletableFuture.allOf(task1, task2, task3).join();long end System.currentTimeMillis();log.info(任务全部完成总耗时 (end - start) 毫秒);
}线程池配置
自行谷歌或百度spring线程池配置基本上很详细了
