17站長網(wǎng) › 首頁 ›網(wǎng)站› 服務(wù)器 › 查看內(nèi)容

Tomcat修正JDK原生線程池bug的實現(xiàn)原理

2022-12-4 12:21| 查看: 2354 |來源: 互聯(lián)網(wǎng)

大家好，現(xiàn)在小編來為大家解答以上問題。Tomcat修正JDK原生線程池bug的實現(xiàn)原理相信很多人還不知道，現(xiàn)在讓我們一起來看看吧！為提高處理能力和并發(fā)度，Web容器一般會把處理請求的任務(wù)放到線程池，而JDK的原生線程池

大家好，現(xiàn)在小編來為大家解答以上問題。Tomcat修正JDK原生線程池bug的實現(xiàn)原理相信很多人還不知道，現(xiàn)在讓我們一起來看看吧！

為提高處理能力和并發(fā)度，Web容器一般會把處理請求的任務(wù)放到線程池，而JDK的原生線程池先天適合CPU密集型任務(wù)，于是Tomcat改造之。

Tomcat 線程池原理

其實ThreadPoolExecutor的參數(shù)主要有如下關(guān)鍵點：

限制線程個數(shù)

限制隊列長度

而Tomcat對這倆資源都需要限制，否則高并發(fā)下CPU、內(nèi)存都有被耗盡可能。
因此Tomcat的線程池傳參：


// 定制的任務(wù)隊列
taskqueue = new TaskQueue(maxQueueSize);

// 定制的線程工廠
TaskThreadFactory tf = new TaskThreadFactory(namePrefix,
							                 daemon,
							                 getThreadPriority()
);

// 定制線程池
executor = new ThreadPoolExecutor(getMinSpareThreads(),
								  getMaxThreads(),
				 			      maxIdleTime, 
				 			      TimeUnit.MILLISECONDS,
				 			      taskqueue,
				 			      tf);

Tomcat對線程數(shù)也有限制，設(shè)置：

核心線程數(shù)（minSpareThreads）
最大線程池數(shù)（maxThreads）

Tomcat線程池還有自己的特色任務(wù)處理流程，通過重寫execute方法實現(xiàn)了自己的特色任務(wù)處理邏輯：

前corePoolSize個任務(wù)時，來一個任務(wù)就創(chuàng)建一個新線程
再有任務(wù)，就把任務(wù)放入任務(wù)隊列，讓所有線程去搶。若隊列滿，就創(chuàng)建臨時線程
總線程數(shù)達到maximumPoolSize，則繼續(xù)嘗試把任務(wù)放入任務(wù)隊列
若緩沖隊列也滿了，插入失敗，執(zhí)行拒絕策略

和 JDK 線程池的區(qū)別就在step3，Tomcat在線程總數(shù)達到最大數(shù)時，不是立即執(zhí)行拒絕策略，而是再嘗試向任務(wù)隊列添加任務(wù)，添加失敗后再執(zhí)行拒絕策略。

具體又是如何實現(xiàn)的呢？


public void execute(Runnable command, long timeout, TimeUnit unit) {
    submittedCount.incrementAndGet();
    try {
        // 調(diào)用JDK原生線程池的execute執(zhí)行任務(wù)
        super.execute(command);
    } catch (RejectedExecutionException rx) {
       // 總線程數(shù)達到maximumPoolSize后，JDK原生線程池會執(zhí)行默認拒絕策略
        if (super.getQueue() instanceof TaskQueue) {
            final TaskQueue queue = (TaskQueue)super.getQueue();
            try {
                // 繼續(xù)嘗試把任務(wù)放入任務(wù)隊列
                if (!queue.force(command, timeout, unit)) {
                    submittedCount.decrementAndGet();
                    // 若緩沖隊列還是滿了，插入失敗，執(zhí)行拒絕策略。
                    throw new RejectedExecutionException("...");
                }
            } 
        }
    }
}

定制任務(wù)隊列

Tomcat線程池的execute方法第一行：


submittedCount.incrementAndGet();

任務(wù)執(zhí)行失敗，拋異常時，將該計數(shù)器減一：


submittedCount.decrementAndGet();

Tomcat線程池使用 submittedCount 變量維護已提交到線程池，但未執(zhí)行完的任務(wù)數(shù)量。

為何要維護這樣一個變量呢？

Tomcat的任務(wù)隊列TaskQueue擴展了JDK的LinkedBlockingQueue，Tomcat給了它一個capacity，傳給父類LinkedBlockingQueue的構(gòu)造器。


public class TaskQueue extends LinkedBlockingQueue {

  public TaskQueue(int capacity) {
      super(capacity);
  }
  ...
}

capacity參數(shù)通過Tomcat的maxQueueSize參數(shù)設(shè)置，但maxQueueSize默認值Integer.MAX_VALUE：當前線程數(shù)達到核心線程數(shù)后，再來任務(wù)的話線程池會把任務(wù)添加到任務(wù)隊列，并且總會成功，就永遠無機會創(chuàng)建新線程了。

為解決該問題，TaskQueue重寫了LinkedBlockingQueue#offer，在合適時機返回false，表示任務(wù)添加失敗，這時線程池就會創(chuàng)建新線程。

什么叫合適時機？


public class TaskQueue extends LinkedBlockingQueue {

  ...
   @Override
  // 線程池調(diào)用任務(wù)隊列的方法時，當前線程數(shù) ＞ core線程數(shù)
  public boolean offer(Runnable o) {

      // 若線程數(shù)已達max，則不能創(chuàng)建新線程，只能放入任務(wù)隊列
      if (parent.getPoolSize() == parent.getMaximumPoolSize()) 
          return super.offer(o);
          
      // 至此，表明 max線程數(shù) > 當前線程數(shù) ＞ core線程數(shù)
      // 說明可創(chuàng)建新線程：
      
      // 1. 若已提交任務(wù)數(shù) ＜ 當前線程數(shù)
      //    表明還有空閑線程，無需創(chuàng)建新線程
      if (parent.getSubmittedCount()<=(parent.getPoolSize())) 
          return super.offer(o);
          
      // 2. 若已提交任務(wù)數(shù) ＞ 當前線程數(shù)
      //    線程不夠用了，返回false去創(chuàng)建新線程
      if (parent.getPoolSize()

所以Tomcat維護 已提交任務(wù)數(shù) 是為了在任務(wù)隊列長度無限時，讓線程池還能有機會創(chuàng)建新線程。
以上Tomcat修正JDK原生線程池bug的實現(xiàn)原理就是小編為大家收集整理的全部內(nèi)容了，希望對大家有所幫助。如果您喜歡這篇文章，可以收藏或分享給您的小伙伴們吧！歡迎持續(xù)關(guān)注我們的后續(xù)更新。

本文最后更新于 2022-12-4 12:21，某些文章具有時效性，若有錯誤或已失效，請在網(wǎng)站留言或聯(lián)系站長：17tui@17tui.com

·END·

站長網(wǎng)微信號：w17tui，關(guān)注站長、創(chuàng)業(yè)、關(guān)注互聯(lián)網(wǎng)人 - 互聯(lián)網(wǎng)創(chuàng)業(yè)者營銷服務(wù)中心

免責聲明：本站部分文章和圖片均來自用戶投稿和網(wǎng)絡(luò)收集，旨在傳播知識，文章和圖片版權(quán)歸原作者及原出處所有，僅供學習與參考，請勿用于商業(yè)用途，如果損害了您的權(quán)利，請聯(lián)系我們及時修正或刪除。謝謝！

下一篇：淺談Tomcat多層容器的設(shè)計上一篇：Tomcat中catalina.bat設(shè)置為UTF-8控制臺出現(xiàn)亂碼

17站長網(wǎng)微信二維碼

始終以前瞻性的眼光聚焦站長、創(chuàng)業(yè)、互聯(lián)網(wǎng)等領(lǐng)域，為您提供最新最全的互聯(lián)網(wǎng)資訊，幫助站長轉(zhuǎn)型升級，為互聯(lián)網(wǎng)創(chuàng)業(yè)者提供更加優(yōu)質(zhì)的創(chuàng)業(yè)信息和品牌營銷服務(wù)，與站長一起進步！讓互聯(lián)網(wǎng)創(chuàng)業(yè)者不再孤獨！

掃一掃，關(guān)注站長網(wǎng)微信

青草久久影院-青草久久伊人-青草久久久-青草久久精品亚洲综合专区-SM双性精跪趴灌憋尿调教H-SM脚奴调教丨踩踏贱奴

Tomcat修正JDK原生線程池bug的實現(xiàn)原理

Tomcat 線程池原理

定制任務(wù)隊列

大家都在看

相關(guān)分類

熱門排行

最近更新