springboot中@EnableAsync与@Async注解使用

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

@Async为异步注解，放到方法上，表示调用该方法的线程与此方法异步执行，需要配合@EnableAsync注解使用。

1、首先演示没有@Async，即没有异步执行的情况

- 创建一个普通类CountNumber，并注入到IOC容器中

package com.example.demo;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component; @Component
public class CountNumber { public void PrintNumber(){
for(int i=; i<; i++){
System.out.println("i = " + i);
}
}
}

- 在spring boot的启动类中获取IOC的bean

package com.example.demo;
import java.util.concurrent.TimeUnit;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.ComponentScan; //@SpringBootApplication
@ComponentScan
public class Springboot3Application { public static void main(String[] args) throws Exception { ConfigurableApplicationContext context = SpringApplication.run(Springboot3Application.class, args); context.getBean(CountNumber.class).PrintNumber();
for(int i=; i<; i++){
System.out.println("------------------");
}
context.close();
}
}

- 运行输出结果：

i =
i =
i =
i =
i =
i =
i =
i =
i =
------------------
------------------
------------------
------------------
------------------
------------------
------------------
------------------
------------------

从输出结果中可以看出，启动类先从IOC容器中获取CountNumber的对象，然后执行该对象的PrintNumber方法，循环打印了9个数字，方法执行结束后，继续回到启动类中往下执行，因此开始执行for循环语句。从整个流程看属于顺序执行的。

2、有@Async，即异步执行的情况

- 创建一个普通类CountNumber，并注入到IOC容器中，并在该类的方法上标注@Async注解，表示该方法是异步执行的。

package com.example.demo;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component; @Component
public class CountNumber {
@Async
public void PrintNumber(){
for(int i=; i<; i++){
System.out.println("i = " + i);
}
}
}

- 从spring boot启动类中获取IOC中的bean，在启动类上标注@EnableAsync注解，启动@Async异步注解。或者在启动类中只标注@SpringBootApplication注解，因为该注解中已经包含了上面两个注解。

package com.example.demo;
import java.util.concurrent.TimeUnit;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync; /*@SpringBootApplication注解与@ComponentScan、@EnableAsync注解达到相同的功效*/
//@SpringBootApplication
@ComponentScan
@EnableAsync
public class Springboot3Application { public static void main(String[] args) throws Exception { ConfigurableApplicationContext context = SpringApplication.run(Springboot3Application.class, args); /*@Async和@EnableAsync配合使用*/
context.getBean(CountNumber.class).PrintNumber();
for(int i=; i<; i++){
TimeUnit.MICROSECONDS.sleep();
System.out.println("------------------");
}
context.close();
}
}

- 执行启动类，输出结果如下：

------------------
------------------
------------------
------------------
------------------
------------------
i =
i =
i =
i =
i =
i =
i =
i =
i =
------------------
------------------
------------------