一、简介

1）在方法上使用该@Async注解，申明该方法是一个异步任务；
2）在类上面使用该@Async注解，申明该类中的所有方法都是异步任务；
3）方法上一旦标记了这个@Async注解，当其它线程调用这个方法时，就会开启一个新的子线程去异步处理该业务逻辑。
4）使用此注解的方法的类对象，必须是spring管理下的bean对象；
5）要想使用异步任务，需要在主类上开启异步配置，即配置上@EnableAsync注解；

二、使用

1、基础代码示例

1）启动类中增加@EnableAsync

以Spring boot 为例，启动类中增加@EnableAsync：

@EnableAsync
@SpringBootApplication
public class ManageApplication {//...
}

2）方法上加@Async注解：

@Component
public class MyAsyncTask {@Asyncpublic void asyncCpsItemImportTask(Long platformId, String jsonList){//...具体业务逻辑}
}

2、隐含问题一：默认线程池配置不合适，导致系统奔溃

@Async注解在使用时，如果不指定线程池的名称，则使用Spring默认的线程池，Spring默认的线程池为SimpleAsyncTaskExecutor。

该类型线程池的默认配置：

    默认核心线程数：8，最大线程数：Integet.MAX_VALUE，队列使用LinkedBlockingQueue，容量是：Integet.MAX_VALUE，空闲线程保留时间：60s，线程池拒绝策略：AbortPolicy。

从最大线程数的配置上，相信你也看到问题了：并发情况下，会无限创建线程、然后OOM、然后系统崩溃。。。

1）问题一解决方法一：

可以通过修改线程池默认配置，来解决上述问题；

spring:task:execution:pool:max-size: 6core-size: 3keep-alive: 3squeue-capacity: 1000thread-name-prefix: name

2）问题一解决方法二：

@Async注解，支持使用自定义线程池，所以通过自定义线程池解决上述问题。
或者说，有时候、实际开发中就是要求你必修使用指定的线程池，@Async注解是支持的。

a、编写配置类

@Configuration
@Data
public class ExecutorConfig{/*** 核心线程*/@Value("${***}")private int corePoolSize;/*** 最大线程*/@Value("${***}")private int maxPoolSize;/*** 队列容量*/@Value("${***}")private int queueCapacity;/*** 保持时间*/@Value("${***}")private int keepAliveSeconds;/*** 名称前缀*/@Value("${***}")private String preFix;@Bean("MyExecutor")public Executor myExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(corePoolSize);executor.setMaxPoolSize(maxPoolSize);executor.setQueueCapacity(queueCapacity);executor.setKeepAliveSeconds(keepAliveSeconds);executor.setThreadNamePrefix(preFix);executor.setRejectedExecutionHandler( new ThreadPoolExecutor.AbortPolicy());executor.initialize();return executor;}
}

b、方法上加@Async注解，同时指定自定义线程池

@Component
public class MyAsyncTask {@Async("MyExecutor") //使用自定义的线程池(执行器)public void asyncCpsItemImportTask(Long platformId, String jsonList){//...具体业务逻辑}
}

3、隐含问题二：异步任务的事务问题

@Async注解由于是异步执行的，在其进行数据库的操作之时，将无法控制事务管理。
解决办法：可以把@Transactional注解放到内部的需要进行事务的方法上；
即将方法中对数据库的操作集中提取出来、放入一个方法中，对该方法加@Transactional注解进行事务控制

4、隐含问题三：在同类方法中调用@Async方法，没有异步执行

@Async的原理概括：

@Async 异步执行，是通过 Spring AOP 动态代理 的方式来实现的。Spring容器启动初始化bean时，判断类中是否使用了@Async注解，如果使用了则为其创建切入点和切入点处理器，根据切入点创建代理，在线程调用@Async注解标注的方法时，会调用代理，执行切入点处理器invoke方法，将方法的执行提交给线程池中的另外一个线程来处理，从而实现了异步执行。

所以，如果a方法调用它同类中的标注@Async的b方法，是不会异步执行的，因为从a方法进入调用的都是该类对象本身，不会进入代理类。因此，相同类中的方法调用带@Async的方法是无法异步的，这种情况仍然是同步。

三、异步任务的返回结果

异步的业务逻辑处理场景 有两种：一个是不需要返回结果，另一种是需要接收返回结果。

不需要返回结果的比较简单，就不多说了。

需要接收返回结果的示例如下：

@Async("MyExecutor")
public Future> queryMap(List ids) {List<> result = businessService.queryMap(ids);..............Map resultMap = Maps.newHashMap();...return new AsyncResult<>(resultMap);
}

调用异步方法的示例：

public Map asyncProcess(List bindDevices,List bindStaffs, String dccId) {Map finalMap =null;// 返回值：Future> asyncResult = MyService.queryMap(ids);try {finalMap = asyncResult.get();} catch (Exception e) {...}return finalMap;
}