深入浅出Java/Spring/Spring Boot异步多线程

一个线程池可以维护多个线程，这些线程等待任务来进行并发处理。线程池模式避免了频繁创建和销毁短期任务线程，复用池中的线程从而提高了性能。线程池中的线程在处理任务时是并发进行的。,,线程池（绿色方块）/等待处理任务队列（蓝色）/处理完成任务（黄色）,该模式允许创建的线程数量及其生命周期。 我们还能够安排任务的执行并将传入的任务保持在队列（Task Queue）中。,线程池数量的大小可根据程序可用的计算资源进行调整，它通常是程序的可调参数，经过调整以优化程序的性能。 确定最佳线程池大小对于优化性能至关重要。,Java中的ThreadPoolExecutor是一个可扩展的线程池的实现，它提供了对很多参数的微调设置。这些参数包括：,ThreadPoolExecutor的构造器：,示例：,corePoolSize：第1个参数“5”。JVM会为前5个任务创建线程，后续的任务会放进队列里，直到队列满为止（第5个参数workQueue，50个任务）。,maximumPoolSize：第2个参数“10”。JVM最多创建10个线程，这意味着当当前正有5个线程运行着5个任务，而这时任务队列的50个任务已满，此时如果有一个新的任务到达队列，JVM将创建一个新的线程，最多创建5个，直至10个。,keepAliveTime：第3个参数“3秒”，超出核心线程而小于最大线程的这些线程，在一定的空闲时间之后将被清除掉。,unit：第4个参数“秒”，keepAliveTime的时间单位。,workQueue：第5个参数“new ArrayBlockingQueue<Runnable>(50)”，任务队列的大小。,JVM创建线程的规则如下：,,Spring/Spring Boot只需要在配置类上注解“@EnableAsync”，在需要使用单独线程的方法上使用“@Async”注解即可。Spring会自动检索线程池的定义，可以是“org.springframework.core.task.TaskExecutor”或者是“java.util.concurrent.Executor”的名为“taskExecutor”的bean。若都未找到，则使用“org.springframework.core.task.SimpleAsyncTaskExecutor”来处理异步方法的调用。,我们最简单可以通过自定一个名为“taskExecutor”的Bean即可。,Spring也提供了“AsyncConfigurer”接口用来定制实现异步多线程相关的配置。,在Spring Boot下，通过“TaskExecutionAutoConfiguration”自动配置类，Spring Boot给我们已经自动配置好了线程池，“TaskExecutionProperties”提供了相关的属性配置。在Spring Boot下我们只需要在配置类上“@EnableAsync”，在“application.yml”上配置即可：,新建一个使用异步方法的类和方法：,在Spring Boot入口类调用：,运行结果：,,从图中可以看出我们的核心线程数量是5，你可以按照上节的“JVM创建线程的规则”来调整核心线程、最大线程、队列数量的来尝试一下观察控制台输出的结果。,我们有时候会在单一的请求中调用多个方法，在同步的方法里，我们都是顺序执行，执行完一个再执行下一个。我们可以通过Spring的“AsyncResult”让多个方法并发执行并聚合他们的结果，并提高性能。,我们先看一下，在同步的情况下是什么样的：,示例中，一个线程顺序执行两个方法，执行结果为：,,在一个线程中,我们现在使用“@Async”使方法变成异步，且使用“AsyncResult”包装异步结果返回。,“CompletableFuture”是Java8引入的，以提供一种编写异步、非阻塞和多线程代码的简单方法。我们使用“AsyncResult”包装返回值，并用它的“.completable()”方法获得“CompletableFuture”对象。,,本文转载自今日「爱科学的卫斯理」，可以通过以下二维码关注。转载本文请联系爱科学的卫斯理。,,