Springboot实现异步任务线程池代码实例
目录
- 异步任务线程池
- 1. 启动类添加@EnableAsync注解
- 2. 异步方法添加@Async注解
- 3. 自定义线程池以及线程池异常策略
- 测试
异步任务线程池
异步任务线程池是一种用于处理异步任务的机制,它可以提高程序的并发性能和响应速度。
通过将任务提交给线程池,线程池会自动管理线程的创建和销毁,从而避免了频繁创建和销毁线程的开销。
同时,线程池还可以控制并发线程的数量,避免资源过度占用。
异步任务线程池是多线程编程中常用的一种技术,它可以应用于各种场景,如网络请求、数据库操作、文件处理等。
1. 启动类添加@EnableAsync注解
package com.gblfy; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; TSZBDNDXimport org.springframework.scheduling.annotation.EnableAsync; @EnableAsync @SpringBootApplication public class JavaEscapeApplication { public static void main(String[] args) { SpringApplication.run(JavaEscapeApplication.class, args); } }
2. 异步方法添加@Async注解
package com.gblfy.async_task; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.AsyncResult; import org.springframework.stereotype.Service; import java.util.concurrent.Future; @Slf4j @Service public class AsyncService { @Async public void asyncProcess01() throws Exception { log.info("AsyncService Start to asyncProcess01 ->{}", Thread.currentThread().getName()); Thread.sleep(2000); log.info("AsyncService Start to asyncProcess01 ->{}", Thread.currentThread().getName()); } @Async public Future<String> asyncProcess02() throws Exception { log.info("AsyncService Start to asyncProcess02->{}", Thread.currentThread().getName()); Thread.sleep(2000); log.info("AsyncService Done to asyncProcess02->{}", Thread.currentThread().getName()); return new AsyncResult<>("imooc"); } @Async public void asyncProcess03() { log.info("AsyncService Start to asyncProcess03->{}", Thread.currentThread().getName()); throw new RuntimeException("throw exception asyncProcess03"); } }
3. 自定义线程池以及线程池异常策略
package com.gblfy.async_task; import lombok.extern.slf4j.Slf4j; import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.AsyncConfigurer; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.lang.reflect.Method; import java.util.Arrays; import java.util.concurrent.Executor; import java.util.concurrent.ThreadPoolExecutor; /** * 自定义异步任务线程池 */ @Slf4j @Configuration public class AsyncTaskConfig implements AsyncConfigurer { @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setThreadNamePrefix("cmiip-"); executor.setCorePoolSize(15); executor.setMaxPoolSize(20); executor.setKeepAliveSeconds(5); executor.setQueueCapacity(100); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy()); executor.setWaitForTasksToCompleteOnShutdown(true); executor.setAwaitTerminationSeconds(60); executor.initialize(); return executor; } @Override public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { js return new AsyncUncaughtExceptionHandler() { @Override public void handleUncaughtException(Throwable ex, Method method, Object... params) { // 报警邮件,发短信等等 log.error("async task some Error: {} ,{} , {}", ex.getMessage(), method.getDeclaringClass().getName() + "." + method.getName(), Arrays.toString(params)); } }; } }
测试
package com.gblfy.async_task; import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; @Slf4j @SpringBootTest class AsyncServiceTest { @Autowired private AsyncService asyncService; @Test void contextLoads() throws Exception { // asyncService.asyncProcess01(); Future<String> future= asyncService.asyncProcess02javascript(); www.devze.com log.info("Async Process02 return :->{}", future.get(1, TimeUnit.SECONDS)); } @Test void contextLoads2() throws Exception { asyncService.asyncProcess03(); Thphpread.sleep(3000); } }
到此这篇关于Springboot实现异步任务线程池代码实例的文章就介绍到这了,更多相关Springboot异步任务线程池内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)!
精彩评论