我就因为说了直接用@Async,面试官就让我回家等通知

一只牛博

发布于 2025-05-30 22:03:48

6600

代码可运行

运行总次数：0

代码可运行

这玩意是什么

@Async 是 Spring 提供的一种注解，用于简化异步方法的开发。它允许我们将特定的方法或类的所有方法标记为异步执行，以提高性能和响应速度，尤其是在执行非阻塞任务或耗时操作时非常有用。

启用异步支持：

必须在 Spring 配置类中添加 @EnableAsync 注解以启用异步处理。

@Configuration
@EnableAsync
public class AsyncConfig {
}

直接用存在的问题

调用的流程

注册代理：

Spring 在初始化时通过 AsyncAnnotationBeanPostProcessor 识别带有 @Async 注解的 bean，在这些 bean 上创建代理对象。

方法拦截：

当代理对象的方法被调用时，Spring 的 AOP 拦截器会检测到 @Async 注解。

这玩意的意思就是你自己定义了线程池那就用你的，否则就用SimpleAsyncTaskExecutor

其一是你在@Async注解中指定了线程池
其二是你没在@Async中指定，但是你在别的地方定义了一个线程池(他也会找到)，但是你如果定义了多个就会出现问题

SimpleAsyncTaskExecutor

这玩意存在大坑，因为当你不指定线程池的话，它会默认无线增加，不会复用线程，严格意义上来讲它并没有真正意义上实现线程池功能

场景测试

注意一定要先加上@EnableAsync注解

不配置线程池

异步方法

@Async()
public void executeTask(int taskId) {
  System.out.println(Thread.currentThread().getName() + " is executing task: " + taskId);
  try {
    // 模拟耗时操作
    Thread.sleep(2000);
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
  }
}

测试调用

@Test
public void parameterFreeAsync() throws InterruptedException {
  // 提交 10 个任务
  for (int i = 0; i < 10; i++) {
    myAsyncService.executeTask(i);
  }

  // 主线程等待所有任务完成
  Thread.sleep(15000);

  // 再提交一些任务，观察线程是否复用
  for (int i = 10; i < 15; i++) {
    myAsyncService.executeTask(i);
  }

  Thread.sleep(10000);
}

结果

上面的图中我们可以看出，线程出现了复用，而且线程名称也并非SimpleAsyncTaskExecutor,很显然不太对。除非Spring在启动的时候默认加了一个线程池，可以在启动的时候打印一下

@PostConstruct
public void checkExecutors() {
  Map<String, Executor> executors = context.getBeansOfType(Executor.class);
  System.out.println("Found Executors: " + executors.size());
  executors.forEach((name, executor) ->
                    System.out.println("Executor Bean Name: " + name + ", Type: " + executor.getClass().getName()));
}

配置一个线程池

配置类

@Bean(name = "customTaskExecutor")
public Executor customTaskExecutor() {
  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
  // 核心线程数
  executor.setCorePoolSize(4);
  // 最大线程数
  executor.setMaxPoolSize(8);
  // 队列容量
  executor.setQueueCapacity(20);
  // 空闲线程存活时间
  executor.setKeepAliveSeconds(10);
  executor.setThreadNamePrefix("ReusableThread-");
  executor.initialize();
  return executor;
}