@Async （异步任务执行）

        Spring框架中的 @Async 注解用于在Spring应用中实现异步任务执行。以下是 @Async 注解的详细说明和使用方式：

基本使用

        启用异步支持：在使用 @Async 之前，需要在配置类上添加 @EnableAsync注解来启用Spring的异步任务执行功能。

@Configuration
@EnableAsync
public class AsyncConfiguration {
    // 其他配置...
}

        使用@Async注解：将@Async注解添加到Spring Bean的方法上，该方法将在单独的线程中异步执行。

@Service
public class AsyncService {
    @Async
    public void asyncMethod() {
        // 这个方法将在一个独立的线程中执行
        // 执行耗时的操作，如数据库查询、网络请求等
    }
}

        注意，被 @Async 标注的方法必须是 void 类型的，且不能有返回值，除非返回类型是Future，这样可以通过 Future 获取异步操作的结果。

异常处理

@Service
public class AsyncService {
    
    @Async
    public CompletableFuture<String> asyncMethod() {
        try {
            // 执行异步操作
            return CompletableFuture.completedFuture("Success");
        } catch (Exception ex) {
            // 处理异常并返回
            return CompletableFuture.failedFuture(ex);
        }
    }
}

自定义线程池

可以通过实现AsyncConfigurer接口来全局配置异步执行器（即线程池）。

@Configuration
@EnableAsync
public class GlobalAsyncConfig implements AsyncConfigurer {
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5); // 核心线程数
        executor.setMaxPoolSize(10); // 最大线程数
        executor.setQueueCapacity(20); // 队列容量
        executor.setThreadNamePrefix("global-"); // 线程名称前缀
        executor.initialize();
        return executor;
    }
}

也可以在 Spring 容器中注册一个线程池 Bean，并在@Async注解中指定使用该线程池。

@Configuration
public class CustomThreadPoolConfig {
    @Bean(name = "customExecutor")
    public ThreadPoolTaskExecutor customExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(3);
        executor.setMaxPoolSize(5);
        executor.setQueueCapacity(10);
        executor.setThreadNamePrefix("custom-");
        executor.initialize();
        return executor;
    }
}

然后，可以在异步方法上指定使用自定义的线程池：

@Service
public class MyService {
    @Async("customExecutor")
    public void executeCustomTask() {
        // 此方法将使用CustomThreadPoolConfig中名为customExecutor的线程池执行
    }
}

注意事项

• @Async注解的方法不能是static类型，否则异步调用不会生效。
• 自调用（从同一类中调用异步方法）将不起作用，因为Spring使用代理来实现异步调用，而代理对象内部的方法调用不会触发AOP拦截。
• 如果需要在异步方法中使用参数，这些参数需要被正确地序列化和传递，因为异步方法将在不同的线程中执行。
• 异步方法的返回值通常应该是Future类型，这样可以获取异步操作的结果。

        通过合理使用@Async注解，你可以在Spring应用中轻松实现异步任务调度，提高系统并发处理能力和用户体验。同时，合理配置线程池并妥善处理异步任务中可能出现的异常，也是保障系统稳定性和健壮性的重要环节。

原文地址：https://blog.csdn.net/q322359/article/details/142875904

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！