jhipster

Jhipster 异步操作

2018-08-06  本文已影响0人  燕凯凯

Jhipster版本 4.14.5

注解介绍

在SpringBoot中实现异步操作需要2个注解 @EnableAsync 和 @Async

@EnableAsync作用在Configuration上,告诉SpringBoot启用@Async注解

@Async可以作用在类或方法上面,表示类内部的所有方法或者指定方法使用异步方式执行

@Async的参数 value 表示使用对应名称的线程池

注意:包含@Async的对象需要注意不允许循环注入

Spring线程池 ThreadPoolTaskExecutor

参数介绍

int corePoolSize:线程池维护线程的最小数量. 

int maximumPoolSize:线程池维护线程的最大数量. 

long keepAliveTime:空闲线程的存活时间. 

TimeUnit unit: 时间单位,现有纳秒,微秒,毫秒,秒枚举值. 

BlockingQueue workQueue:持有等待执行的任务队列. 

RejectedExecutionHandler handler: 

用来拒绝一个任务的执行,有两种情况会发生这种情况。 

一是在execute方法中若addIfUnderMaximumPoolSize(command)为false,即线程池已经饱和; 

二是在execute方法中, 发现runState!=RUNNING || poolSize == 0,即已经shutdown,就调用ensureQueuedTaskHandled(Runnable command),在该方法中有可能调用reject。

ThreadPoolExecutor池子的处理流程如下:  

1)当池子大小小于corePoolSize就新建线程,并处理请求

2)当池子大小等于corePoolSize,把请求放入workQueue中,池子里的空闲线程就去从workQueue中取任务并处理

3)当workQueue放不下新入的任务时,新建线程入池,并处理请求,如果池子大小撑到了maximumPoolSize就用RejectedExecutionHandler来做拒绝处理

4)另外,当池子的线程数大于corePoolSize的时候,多余的线程会等待keepAliveTime长的时间,如果无请求可处理就自行销毁

其会优先创建  CorePoolSiz 线程, 当继续增加线程时,先放入Queue中,当 CorePoolSiz  和 Queue 都满的时候,就增加创建新线程,当线程达到MaxPoolSize的时候,就会抛出错 误 org.springframework.core.task.TaskRejectedException

另外MaxPoolSize的设定如果比系统支持的线程数还要大时,会抛出java.lang.OutOfMemoryError: unable to create new native thread 异常。

参考资料

spring线程池ThreadPoolTaskExecutor与阻塞队列BlockingQueue

上一篇下一篇

猜你喜欢

热点阅读