SpringBoot-异步编程：@Async原理、使用及自定义线程池

这篇文章距离上次修改已过425天，其中的内容可能已经有所变动。

Spring Boot中的@Async注解用于创建异步行为，允许方法在不阻塞调用线程的情况下执行。

@Async的使用

在Spring Boot主类或配置类中启用异步支持：




@EnableAsync
@SpringBootApplication
public class MyApp {
    public static void main(String[] args) {
        SpringApplication.run(MyApp.class, args);
    }
}

在服务类中使用@Async注解：




@Service
public class AsyncService {
 
    @Async
    public Future<String> executeAsyncTask() {
        // 模拟长时间运行的任务
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new AsyncResult<>("任务完成");
    }
}

调用异步方法：




@RestController
public class AsyncController {
 
    @Autowired
    private AsyncService asyncService;
 
    @GetMapping("/async")
    public String asyncMethod() throws ExecutionException, InterruptedException {
        Future<String> future = asyncService.executeAsyncTask();
        return future.get(); // 异步方法将在这里被调用，而不会阻塞主线程
    }
}

@Async的原理

Spring通过使用Java的Executor框架为@Async注解提供支持。Spring自动配置一个线程池来处理异步方法的执行。

自定义线程池

可以通过创建配置类并定义一个Executor的Bean来自定义线程池：




@Configuration
public class AsyncConfig implements AsyncConfigurer {
 
    @Override
    @Bean
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5); // 核心线程数
        executor.setMaxPoolSize(10); // 最大线程数
        executor.setQueueCapacity(25); // 队列大小
        executor.initialize();
        return executor;
    }
}

在这个配置类中，我们定义了一个ThreadPoolTaskExecutor，并设置了线程池的参数，如核心线程数、最大线程数和队列大小。然后通过executor.initialize()初始化线程池。

在服务类中使用自定义线程池：




@Service
public class AsyncServiceWithCustomThreadPool {
 
    private final Executor executor;
 
    @Autowired
    public AsyncServiceWithCustomThreadPool(Executor executor) {
        this.executor = executor;
    }
 
    @Async
    public void executeAsyncTaskWithCustomThreadPool() {
        // 异步任务的逻辑
    }
}

在这个例子中，我们注入了Executor Bean，并在异步方法中使用它。

注意事项

确保在启动类上使用@EnableAsync注解来启用异步支持。
异步方法应该返回Future或其子类型，如Future<T>，