SpringBoot高级并发实践：自定义线程池与@Async异步调用深度解析

文章目录

同步编程&异步编程

在Java并发编程中，同步和异步是两种常见的处理方式。

同步是指多个任务按顺序执行，一个任务的执行需要等待上一个任务的完成。而异步则是指多个任务可以并行执行，不需要等待上一个任务完成。

在多线程编程中，同步是指多个线程按顺序执行，一个线程的执行需要等待上一个线程的完成；而异步是指多个线程可以并发执行，不需要等待其他线程的完成。

在实际应用中，同步通常适用于简单的线性任务，比如IO操作、数据库读写等；而异步通常适用于复杂的并发任务，比如并行计算、大规模数据处理等。

线程池

为什么要使用线程池？

当创建使用线程，需要进行new Thread操作，在JVM的堆内存中创建新的对象地址。
当使用完毕后，需要等待JVM的GC操作，检索Root根释放堆中的垃圾信息。
频繁的创建线程和销毁垃圾，极大的消耗了系统的资源，降低了处理其他业务的性能问题。

创建一个池，保存初始化的线程，用的时候取，不用的时候放入池中等待下次使用。
减少创建的线程数。

Spring自定义线程池

/**
 * @author linghu
 * 自定义线程池配置
 * 需要使用线程池，则开启当前配置
 */@ConfigurationpublicclassThreadPoolConfig{@BeanpublicThreadPoolExecutormyThreadPool(){ThreadPoolExecutor threadPoolExecutor =newThreadPoolExecutor(2,//核心线程数，一直都能工作的数量5,//请求处理大的时候，可以开放的最大工作数、最大线程数3,//开启最大工作数后，当无请求时，还让其存活的时间、线程活跃时间TimeUnit.SECONDS,//存活时间的单位newLinkedBlockingDeque<>(10),//阻塞队列，保存操作请求线程Executors.defaultThreadFactory(),//创建线程的工厂类newThreadPoolExecutor.AbortPolicy()//设置拒绝策略);return threadPoolExecutor;}}

具体案例：

@RestControllerpublicclassTestController{@AutowiredprivateThreadPoolExecutor threadPoolExecutor;@AutowiredprivateMyService myService;@RequestMapping("/getThreadPoolInfo")publicvoidgetThreadPoolInfo(){System.out.println("getActiveCount--"+threadPoolExecutor.getActiveCount());System.out.println("getCorePoolSize--"+threadPoolExecutor.getCorePoolSize());System.out.println("getPoolSize--"+threadPoolExecutor.getPoolSize());}@RequestMapping("/test1")publicStringtest1(){System.out.println("进入test1 "+System.currentTimeMillis());/** 这种调用其实比较复杂，还有更简单的调用法则 */
        threadPoolExecutor.execute(()->{try{System.out.println("线程池处理数据  start "+System.currentTimeMillis());TimeUnit.SECONDS.sleep(3);System.out.println("线程池处理数据  end "+System.currentTimeMillis());}catch(InterruptedException e){
                e.printStackTrace();}});System.out.println("线程池调用结束 "+System.currentTimeMillis());return"6666";}}

测试：

上面自定义的线程池能够实现异步调用执行方法。

SpringBoot轻松调用线程池

SpringBoot自定义线程池同上面的Spring，只不过多了几个注解简化了一些操作。SpringBoot能够通过这个注解更轻松的调用线程池。

我们将类上添加注解

@EnableAsync

开启异步调用，让在需要使用的地方，直接使用

@Async

就可以了。

@Configuration@EnableAsync//注解开启异步调用AsyncpublicclassThreadPoolConfig{@BeanpublicThreadPoolExecutormyThreadPool(){ThreadPoolExecutor threadPoolExecutor =newThreadPoolExecutor(2,//核心线程数，一直都能工作的数量5,//请求处理大的时候，可以开放的最大工作数、最大线程数3,//开启最大工作数后，当无请求时，还让其存活的时间、线程活跃时间TimeUnit.SECONDS,//存活时间的单位newLinkedBlockingDeque<>(10),//阻塞队列，保存操作请求线程Executors.defaultThreadFactory(),//创建线程的工厂类newThreadPoolExecutor.AbortPolicy()//设置拒绝策略);return threadPoolExecutor;}}

然后编写一个测试类，同时也需要将具体的异步业务单独独立出来：

@RequestMapping("/test2")publicvoidtest2()throwsInterruptedException{System.out.println("进入test2 "+System.currentTimeMillis());
        myService.service1();System.out.println("调用结束 "+System.currentTimeMillis());}

服务类的代码如下所示：

// 具体使用哪个线程池@Async("myThreadPoolExecutor")publicvoidservice1()throwsInterruptedException{System.out.println("----- service1 start --------"+System.currentTimeMillis());TimeUnit.SECONDS.sleep(3);System.out.println("----- service1 end --------"+System.currentTimeMillis());}

执行请求：

http://localhost:8080/test2

总结

我们其实用注解

@Async("myThreadPoolExecutor")

取代了

  threadPoolExecutor.execute(()->{try{System.out.println("线程池处理数据  start "+System.currentTimeMillis());TimeUnit.SECONDS.sleep(3);System.out.println("线程池处理数据  end "+System.currentTimeMillis());}catch(InterruptedException e){
                e.printStackTrace();}});

测试demo链接

https://gitee.com/xiangjiaobunana/springboot-thread-pool