轉(zhuǎn)載自?Spring開(kāi)啟方法異步執(zhí)行

?

?

@EnableAsync

@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) @Documented @Import(AsyncConfigurationSelector.class) public @interface EnableAsync {Class<? extends Annotation> annotation() default Annotation.class;boolean proxyTargetClass() default false;AdviceMode mode() default AdviceMode.PROXY;int order() default Ordered.LOWEST_PRECEDENCE;}

@EnableAsync注解即開(kāi)啟Spring對(duì)方法異步執(zhí)行的能力，需要和注解@Configuration配合使用。

@Configuration @EnableAsync public class AppConfig {}

也可以自定義線程池

@Configuration@EnableAsyncpublic class AppConfig implements AsyncConfigurer {@Overridepublic Executor getAsyncExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(7);executor.setMaxPoolSize(42);executor.setQueueCapacity(11);executor.setThreadNamePrefix("MyExecutor-");executor.initialize();return executor;}@Overridepublic AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {return MyAsyncUncaughtExceptionHandler();}}

@Async

@Target({ElementType.METHOD, ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Async {String value() default "";}

在要異步執(zhí)行的方法上使用@Async注解，下面是一個(gè)沒(méi)有返回值，一個(gè)帶有返回值的異步調(diào)用的示例。

@Component public class AsyncTask {@Asyncpublic void task1() {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}}@Asyncpublic Future<String> task2() {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}return new AsyncResult<String>("javastack"); ?}}

測(cè)試代碼

@RunWith(SpringRunner.class) @SpringBootTest public class AsyncTest {private final static Logger log = LoggerFactory.getLogger(AsyncTest.class);@Autowiredprivate AsyncTask asyncTask;@Testpublic void testTask1(){log.info("start");asyncTask.task1();log.info("finish");}@Testpublic void testTask2() ?{log.info("start");Future<String> future = asyncTask.task2();while (true) {if (future.isDone()) {try {log.info("result is " + future.get());} catch (Exception e) {e.printStackTrace();} break;}}log.info("finish");}}

注意事項(xiàng)

1、使用注意

@Async只能使用到被代理的對(duì)象方法上，即代理類的入口方法處，且方法必須是public的。

2、事務(wù)處理機(jī)制

使用@Async異步注解不能和@Transaction事務(wù)注解在同一個(gè)方法上同時(shí)使用，不然事務(wù)注解將無(wú)效。

要使用事務(wù)，需要把事務(wù)注解提取到方法里面的子方法上。

?

總結(jié)

以上是生活随笔為你收集整理的Spring开启方法异步执行的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。