SpringBoot的线程调度

Spring Boot默认提供了一个ThreadPoolTaskExecutor作为线程调度器，只需要在配置类中使用注解EnableAsync即可开启异步线程调度。在实际要执行的Bean中使用@Async注解来声明这个方法是异步方法，需要通过线程调度器来执行。

示例代码如下：

Application类，开启异步线程调度

@SpringBootApplication

@EnableAsync

public class TestApplication {

	public static void main(String[] args) {

		SpringApplication.run(TestApplication.class, args);

	}

}

异步任务类，声明execute()方法通过线程调度器执行

@Service

public class TestAsync {

  private static AtomicInteger count = new AtomicInteger(0);

  @Async

  public String execute() {

    System.out.println("begin execute TestAsync: " + count.incrementAndGet());

    try {

      Thread.sleep(10000);

    } catch (InterruptedException e) {

      e.printStackTrace();

    }

    System.out.println("finished execute TestAsync");

    return "result";

  }

}

要注意的问题：

(1)这里的@Async注解必须要声明在Bean对外提供的方法上，如果这个方法不是由其它类直接调用，而是这个类的其它方法间接调用，则不生效。
(2)@Async注解声明的方法，返回类型要么声明为void，要么声明为Future。因为方法是异步调用，因此无法立即返回结果，如果声明为其它返回类型，则获取到的是null。声明为Future，则可以获取到任务的执行结果。

Controller类

@RestController

public class TestAsyncController {

  @Autowired

  private TestAsync testAsync;

  @RequestMapping(value = "/async", method = RequestMethod.GET)

  public String async() {

    System.out.println("before execute TestAsync");

    String result =  testAsync.outexecute();

    System.out.println("after execute TestAsync");

    return result;

  }

}

这里获取到的result值null，因此获取这个返回值没有什么意义。

Spring Boot线程调度有以下几个参数可以配置(2.1版本之后才有)：
spring.task.execution.pool.core-size # 核心线程数，默认为8
spring.task.execution.pool.queue-capacity # 队列容量，默认为无限大
spring.task.execution.pool.max-size # 最大线程数，默认为无限大
这三个参数的关系如下：
如果当前要执行的任务数超过core-size，则任务会放到队列里面等待执行，等核心线程中有任务执行完成之后，再取出队列中的任务进行调度执行。
如果等待队列已经满了，再收到新任务时，则核心线程会自动扩容，最大扩展到max-size。

spring.task.execution.pool.allow-core-thread-timeout # 是否允许回收空闲的线程，默认为true
spring.task.execution.pool.keep-alive # 空闲的线程可以保留多少秒，默认为60。如果超过这个时间没有任务调度，则线程会被回收
spring.task.execution.thread-name-prefix # 线程名前缀，默认为thread-

自定义线程调度器
如果不想使用Spring Boot自带的线程调度器，可以通过实现AsyncConfigurer接口来定义自己的线程调度器。
示例代码如下：

@Configuration

@EnableAsync

public class AppConfig implements AsyncConfigurer {

  @Override

  public Executor getAsyncExecutor() {

    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

    executor.setCorePoolSize(7);

    executor.setMaxPoolSize(42);

    executor.setQueueCapacity(11);

    executor.setThreadNamePrefix("MyExecutor-");

    executor.initialize();

    return executor;

  }

  @Override

  public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {

    return MyAsyncUncaughtExceptionHandler();

  }

}

巴特西

SpringBoot的线程调度

最新文章

热门文章