SpringBoot中如何配置线程池拒绝策略,妥善处理好溢出的任务--688IT编程网

SpringBoot中如何配置线程池拒绝策略，妥善处理好溢出的任务

通过之前三篇关于Spring Boot异步任务实现的博⽂，我们分别学会了、、。今天这篇，我们继续对上⾯的知识进⾏完善和优化！

如果你已经看过上⾯⼏篇内容并已经掌握之后，⼀起来思考下⾯这个问题：

假设，线程池配置为核⼼线程数2、最⼤线程数2、缓冲队列长度2。此时，有5个异步任务同时开始，会发⽣什么？

场景重现

我们先来把上⾯的假设⽤代码实现⼀下：

第⼀步：创建Spring Boot应⽤，根据上⾯的假设写好线程池配置。

@EnableAsync

@SpringBootApplication

public class Chapter78Application {

public static void main(String[] args) {

SpringApplication.run(Chapter78Application.class, args);

}

@EnableAsync

@Configuration

class TaskPoolConfig {

@Bean

public Executor taskExecutor1() {

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

executor.setCorePoolSize(2);

executor.setMaxPoolSize(2);

executor.setQueueCapacity(2);

executor.setKeepAliveSeconds(60);

executor.setThreadNamePrefix("executor-1-");

return executor;

}

第⼆步：⽤@Async注解实现⼀个部分任务

@Slf4j

@Component

public class AsyncTasks {

public static Random random = new Random();

@Async("taskExecutor1")

public CompletableFuture<String> doTaskOne(String taskNo) throws Exception {

log.info("开始任务：{}", taskNo);

long start = System.currentTimeMillis();

Thread.Int(10000));

long end = System.currentTimeMillis();

log.info("完成任务：{}，耗时：{} 毫秒", taskNo, end - start);

return CompletableFuturepletedFuture("任务完成");

}

第三步：编写测试⽤例

@Slf4j

@SpringBootTest

public class Chapter78ApplicationTests {

@Autowired

private AsyncTasks asyncTasks;

@Test

public void test2() throws Exception {

// 线程池配置：core-2,max-2,queue=2，同时有5个任务，出现下⾯异常：

// ask.TaskRejectedException: Executor [urrent.ThreadPoolExecutor@59901c4d[Running, pool size = 2,

/ active threads = 0, queued tasks = 2, completed tasks = 4]] did not accept task: urrent.CompletableFuture$AsyncSupply@408e96d9

long start = System.currentTimeMillis();

// 线程池1

CompletableFuture<String> task1 = asyncTasks.doTaskOne("1");

CompletableFuture<String> task2 = asyncTasks.doTaskOne("2");

CompletableFuture<String> task3 = asyncTasks.doTaskOne("3");

CompletableFuture<String> task4 = asyncTasks.doTaskOne("4");

CompletableFuture<String> task5 = asyncTasks.doTaskOne("5");

// ⼀起执⾏

CompletableFuture.allOf(task1, task2, task3, task4, task5).join();

long end = System.currentTimeMillis();

log.info("任务全部完成，总耗时：" + (end - start) + "毫秒");

}

执⾏⼀下，可以类似下⾯这样的⽇志信息：

2021-09-22 17:33:08.159 INFO 21119 --- [ executor-1-2] com.didispace.chapter78.AsyncTasks : 开始任务：2

2021-09-22 17:33:08.159 INFO 21119 --- [ executor-1-1] com.didispace.chapter78.AsyncTasks : 开始任务：1

ask.TaskRejectedException: Executor [urrent.ThreadPoolExecutor@3e1a3801[Running, pool size = 2, active threads = 2, queued tasks = 2, completed tasks = 0]] did not accept task: urrent. at org.ute(ThreadPoolTaskExecutor.java:324)

at urrent.CompletableFuture.asyncSupplyStage(CompletableFuture.java:1604)

at urrent.CompletableFuture.supplyAsync(CompletableFuture.java:1830)

at org.springframework.aop.interceptor.AsyncExecutionAspectSupport.doSubmit(AsyncExecutionAspectSupport.java:274)

at org.springframework.aop.interceptor.AsyncExecutionInterceptor.invoke(AsyncExecutionInterceptor.java:129)

at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)

at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750)

at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:692)

at com.didispace.chapter78.AsyncTasks$$EnhancerBySpringCGLIB$$c7e8d57b.doTaskOne(<generated>)

at com.didispace.st2(Chapter78ApplicationTests.java:51)

flect.NativeMethodAccessorImpl.invoke0(Native Method)

flect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

flect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at flect.Method.invoke(Method.java:498)

at org.junit.platformmons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)

at org.ution.MethodInvocation.proceed(MethodInvocation.java:60)

at org.ution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)

at org.sion.TimeoutExtension.intercept(TimeoutExtension.java:149)

at org.sion.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)

at org.sion.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)

at org.ution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)

at org.ution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)

at org.ution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)

at org.ution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)

at org.ution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)

at org.ution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)

at org.ution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)

at org.ution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)

at org.ine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)