聚色网-【ONSD-345】交わる体液、濃密セックス4時間 Tomcat怎么修正JDK原生线程池Bug?
你的位置:聚色网 > 哥要搞 > 【ONSD-345】交わる体液、濃密セックス4時間 Tomcat怎么修正JDK原生线程池Bug?
【ONSD-345】交わる体液、濃密セックス4時間 Tomcat怎么修正JDK原生线程池Bug?
发布日期:2024-08-03 16:42    点击次数:127

【ONSD-345】交わる体液、濃密セックス4時間 Tomcat怎么修正JDK原生线程池Bug?

[[418595]]【ONSD-345】交わる体液、濃密セックス4時間

为培植处置才智和并发度,Web容器一般会把处置申请的任务放到线程池,而JDK的原生线程池先天得当CPU密集型任务,并不得当咱们频频的 I/O 密集任务处置,于是Tomcat改变之。

Tomcat 线程池旨趣

其实ThreadPoolExecutor的参数主要有如下关节点:

适度线程个数 【ONSD-345】交わる体液、濃密セックス4時間

免费视频 适度队伍长度

而Tomcat对这俩资源王人需要适度,不然高并发下CPU、内存王人有被消耗可能。因此Tomcat的线程池传参:

// 定制的任务队伍 taskqueue = new TaskQueue(maxQueueSize);  // 定制的线程工场 TaskThreadFactory tf = new TaskThreadFactory(namePrefix,                                daemon,                                getThreadPriority() );  // 定制线程池 executor = new ThreadPoolExecutor(getMinSpareThreads(),                   getMaxThreads(),                      maxIdleTime,                       TimeUnit.MILLISECONDS,                      taskqueue,                      tf); 

Tomcat对线程数也有适度,诞生:

中枢线程数(minSpareThreads) 最大线程池数(maxThreads)

Tomcat线程池还有我方的特点任务处置进程,通过重写execute步骤终端了我方的特点任务处置逻辑:

前corePoolSize个任务时,来一个任务就创建一个新线程 再有任务,就把任务放入任务队伍,让统共线程去抢。若队伍满,就创建临时线程 总线程数达到maximumPoolSize,则接续尝试把任务放入任务队伍 若缓冲队伍也满了,插入失败,实行拆开计谋

和 JDK 线程池的分辨就在step3,Tomcat在线程总和达到最大数时,不是立即实行拆开计谋,而是再尝试向任务队伍添加任务,添加失败后再实行拆开计谋。

具体又是怎么终端的呢? 

public void execute(Runnable command, long timeout, TimeUnit unit) {     submittedCount.incrementAndGet();     try {         // 调用JDK原生线程池的execute实行任务         super.execute(command);     } catch (RejectedExecutionException rx) {        // 总线程数达到maximumPoolSize后,JDK原生线程池会实行默许拆开计谋         if (super.getQueue() instanceof TaskQueue) {             final TaskQueue queue = (TaskQueue)super.getQueue();             try {                 // 接续尝试把任务放入任务队伍                 if (!queue.force(command, timeout, unit)) {                     submittedCount.decrementAndGet();                     // 若缓冲队伍已经满了,插入失败,实行拆开计谋。                     throw new RejectedExecutionException("...");                 }             }          }     } } 
定制任务队伍

Tomcat线程池的execute步骤第一滑:

submittedCount.incrementAndGet(); 

任求实行失败,抛极度时,将该计数器减一:

submittedCount.decrementAndGet(); 

Tomcat线程池使用 submittedCount 变量珍爱已提交到线程池,但未实行完的任务数目。

为何要珍爱这么一个变量呢?

Tomcat的任务队伍TaskQueue膨胀了JDK的LinkedBlockingQueue,Tomcat给了它一个capacity,传给父类LinkedBlockingQueue的构造器。

public class TaskQueue extends LinkedBlockingQueue<Runnable> {    public TaskQueue(int capacity) {       super(capacity);   }   ... } 

capacity参数通过Tomcat的 maxQueueSize 参数诞生,但maxQueueSize默许值为Integer.MAX_VALUE:这么,面前方程数达到中枢线程数后,再来的任务,线程池会把任务添加到任务队伍,何况总会见效,就恒久无契机创建新线程了。

为此,TaskQueue重写了LinkedBlockingQueue#offer,在合应时机复返false,示意任务添加失败,线程池此时会创建新的线程。

什么叫合应时机?

public class TaskQueue extends LinkedBlockingQueue<Runnable> {    ...    @Override   // 线程池调用任务队伍的步骤时,面前方程数 > core线程数   public boolean offer(Runnable o) {        // 若线程数已达max,则不可创建新线程,只可放入任务队伍       if (parent.getPoolSize() == parent.getMaximumPoolSize())            return super.offer(o);                  // 至此,标明 max线程数 > 面前方程数 > core线程数       // 评释可创建新线程:              // 1. 若已提交任务数 < 面前方程数       //    标明还有舒适线程,无需创建新线程       if (parent.getSubmittedCount()<=(parent.getPoolSize()))            return super.offer(o);                  // 2. 若已提交任务数 > 面前方程数       //    线程不够用了,复返false去创建新线程       if (parent.getPoolSize()<parent.getMaximumPoolSize())            return false;                  // 默许情况下老是把任务放入任务队伍       return super.offer(o);   }    } 

是以Tomcat珍爱 已提交任务数 是为了在职务队伍长度无穷时,让线程池还能有契机创建新线程。

 



相关资讯