建站
咨詢
售后
建站咨詢
新聞中心
哈嘍，大家好，我是了不起。
高考結(jié)束了，依然祝高考學(xué)子們?nèi)〉煤贸煽?jī)，然后報(bào)考計(jì)算機(jī)專業(yè)，然后快點(diǎn)畢業(yè)，來(lái)接收哥哥姐姐們留下的代碼文明。
接到某城舉報(bào)，某迪泄露高考題目。
最近生產(chǎn)環(huán)境各種問(wèn)題，幾百臺(tái)設(shè)備停擺，真的是亞歷山大。接手了別人的代碼，只能硬著頭皮改了，一不留神就恰班到10點(diǎn)多了。
今天還是說(shuō)一下線程池的兩個(gè)思考。
池子
我們常用的線程池，
1. JDK的ThreadPoolExecutor.
2. CompletableFutures 默認(rèn)使用了ForkJoinPool.commonPool()。
CompletableFuture.supplyAsync(()->{ return "hello word";});3. 還有Tomcat中的線程池
org.apache.tomcat.util.threads.TaskQueue
org.apache.tomcat.util.threads.ThreadPoolExecutor
線程池維護(hù)多個(gè)線程，等待監(jiān)督管理者分配可并發(fā)執(zhí)行的任務(wù)。這種做法，一方面避免了處理任務(wù)時(shí)創(chuàng)建銷毀線程開銷的代價(jià)，另一方面避免了線程數(shù)量膨脹導(dǎo)致的過(guò)分調(diào)度問(wèn)題，保證了對(duì)內(nèi)核的充分利用。
JDK 線程池
public ThreadPoolExecutor(
int corePoolSize, //核心線程數(shù)
int maximumPoolSize,//最大線程數(shù)
long keepAliveTime, //大于核心線程數(shù)量的線程存活時(shí)間，如果沒(méi)有新任務(wù)就會(huì)關(guān)閉
TimeUnit unit, // 時(shí)間單位
BlockingQueue workQueue, //線程等待隊(duì)列
ThreadFactory threadFactory,//創(chuàng)建線程的工廠
RejectedExecutionHandler handler//拒絕策略
) { JDK線程池執(zhí)行任務(wù)：
- 提交任務(wù)給線程池后，線程池會(huì)檢查線程池中正在運(yùn)行的線程數(shù)量，如果線程數(shù)量小于核心線程，則創(chuàng)建一個(gè)新的線程來(lái)處理任務(wù)。
- 如果線程池中線程數(shù)量達(dá)到和corePoolSize的大小，則將線程放入等待隊(duì)列BlockingQueue中。
- 如果提交任務(wù)時(shí)連等待隊(duì)列都已經(jīng)滿了的話，線程池會(huì)繼續(xù)創(chuàng)建新的線程來(lái)處理任務(wù)，直到線程池?cái)?shù)量達(dá)到maximumPoolSize。
- 如果線程數(shù)量達(dá)到了最大容量，則會(huì)執(zhí)行拒絕策略。
這里需要注意直接使用LinkedBlockingQueue阻塞隊(duì)列作為線程池會(huì)存在一個(gè)問(wèn)題，當(dāng)workcount > corePool時(shí)優(yōu)先進(jìn)入隊(duì)列排隊(duì)， 當(dāng)請(qǐng)求并發(fā)過(guò)多時(shí)會(huì)導(dǎo)致請(qǐng)求緩慢，隊(duì)列太長(zhǎng)可能會(huì)出現(xiàn)內(nèi)存溢出（先排隊(duì)再漲線程池）
Tomcat線程池
下面時(shí)Tomcat線程池的構(gòu)造方法
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) {
this.ctl = new AtomicInteger(ctlOf(-536870912, 0));
this.mainLock = new ReentrantLock();
this.workers = new HashSet();
this.termination = this.mainLock.newCondition();
this.submittedCount = new AtomicInteger(0);
this.lastContextStoppedTime = new AtomicLong(0L);
this.lastTimeThreadKilledItself = new AtomicLong(0L);
this.threadRenewalDelay = 1000L;
if (corePoolSize >= 0 && maximumPoolSize > 0 && maximumPoolSize >= corePoolSize && keepAliveTime >= 0L) {
if (workQueue != null && threadFactory != null && handler != null) {
this.corePoolSize = corePoolSize;
this.maximumPoolSize = maximumPoolSize;
this.workQueue = workQueue;
this.keepAliveTime = unit.toNanos(keepAliveTime);
this.threadFactory = threadFactory;
this.handler = handler;
this.prestartAllCoreThreads();
} else {
throw new NullPointerException();
}
} else {
throw new IllegalArgumentException();
}
} Tomcat主要針對(duì)web接口請(qǐng)求，不能因?yàn)長(zhǎng)inkedBlockingQueue的排隊(duì)導(dǎo)致接口出現(xiàn)大量延遲和緩慢， 從而使用了tomcat的TaskQueue，TaskQueue繼承了JDK的LinkedBlockingQueue 并擴(kuò)展了JDK線程池的功能。
主要有一下幾點(diǎn)優(yōu)化：
- Tomcat的ThreadPoolExecutor使用的TaskQueue，是無(wú)界的LinkedBlockingQueue，但是通過(guò)taskQueue的offer方法覆蓋了LinkedBlockingQueue的offer方法，修改了線程池增長(zhǎng)規(guī)則，使得線程池能在任務(wù)較多的情況下增長(zhǎng)線程池?cái)?shù)量。（先漲線程池再排隊(duì)。）
- Tomcat的ThreadPoolExecutor改寫了execute方法，當(dāng)任務(wù)被reject時(shí)，捕獲異常，會(huì)強(qiáng)制入隊(duì)
public void execute(Runnable command, long timeout, TimeUnit unit) {
this.submittedCount.incrementAndGet();
try {
this.executeInternal(command);
} catch (RejectedExecutionException var9) {
if (!(this.getQueue() instanceof TaskQueue)) {
this.submittedCount.decrementAndGet();
throw var9;
}
TaskQueue queue = (TaskQueue)this.getQueue();
try {
if (!queue.force(command, timeout, unit)) {
this.submittedCount.decrementAndGet();
throw new RejectedExecutionException(sm.getString("threadPoolExecutor.queueFull"));
}
} catch (InterruptedException var8) {
this.submittedCount.decrementAndGet();
throw new RejectedExecutionException(var8);
}
}
}那個(gè)線程池適合
我們看看AI如何回復(fù)
了不起認(rèn)為大多數(shù)情況下使用JDK的線程池就夠用了，如果覺得線程數(shù)據(jù)處理不過(guò)來(lái)，需要多一點(diǎn)線程直接增加核心線程數(shù)量設(shè)置就可以了。針對(duì)資源比較緊張，對(duì)線程使用代價(jià)比較高時(shí)可以考慮。
tomcat對(duì)線程池做過(guò)優(yōu)化，也必然是有一定的考量，對(duì)于線程資源的使用頻率比較高的情況下可以使用。
了不起之前也有對(duì)應(yīng)的不同的例子來(lái)說(shuō)明不同點(diǎn)。這里再放出來(lái)讓大家體會(huì)一下！
JDK線程池，線程資源較珍貴
- 有一家工廠建立，開始的時(shí)候只有10個(gè)工人，然后工廠的活越來(lái)越多，招聘新的工人肯定不是最好的策略，所以多出來(lái)的活暫時(shí)只能等著，進(jìn)行排隊(duì)。（這個(gè)例子中工廠的活多了，立馬去招人肯定是不可能，只能先排單）
- 后面工廠的業(yè)務(wù)越來(lái)越多，任務(wù)擠壓過(guò)多，原來(lái)的工人干活已經(jīng)不能滿足業(yè)務(wù)需求了。為了最大化效益，招聘新的工人勢(shì)在必行，于是就招聘了新的工人，所有的工人一起來(lái)干活，加快效率。
- 當(dāng)工廠的工人數(shù)量達(dá)到飽和之后，仍然不停的新增業(yè)務(wù)，此時(shí)工廠已經(jīng)飽和，沒(méi)有辦法再繼續(xù)接單。那么只能采取別的方案（拒絕策略），找別的工廠干，或者新建工廠。
- 當(dāng)后面業(yè)務(wù)量比較小的時(shí)候，新招的工人就會(huì)慢慢的裁剪（線程一段時(shí)間不使用就會(huì)關(guān)掉?。?。
Tomcat線程池，線程資源使用比較頻繁
- 某學(xué)校有一個(gè)食堂，大廳里面日常至少擺100把椅子（min-spare）供學(xué)生們吃飯。
- 然而當(dāng)同時(shí)吃飯的同學(xué)大于100人的時(shí)候，食堂會(huì)增加一些椅子（創(chuàng)建線程），并且這些椅子也不會(huì)立馬收回去，一段時(shí)間沒(méi)有人使用才會(huì)收回。
- 但是食堂里面最多可以擺500把椅子（maxThreads）。然后超過(guò)500人吃飯同時(shí)吃飯的話，其他人就只能在大廳里面排隊(duì)等別人吃完。食堂大廳里面可以容納1000人進(jìn)行排隊(duì)等候（maxConnections）。
- 當(dāng)食堂大廳1000人都排滿了，那么就只能到食堂外面排隊(duì)了，外面排隊(duì)最多一直能排200人（acceptCount）。這個(gè)時(shí)候如果再有人過(guò)來(lái)要吃飯，而且還排不上隊(duì)，就會(huì)等到不耐煩（time out），也會(huì)有人來(lái)告訴后來(lái)的同學(xué)，別來(lái)了人都滿了，上其他地方吃飯去吧。（reject）
當(dāng)前題目：珍貴的線程資源，JDKVSTomcat
瀏覽路徑：http://www.dlmjj.cn/article/cdhghig.html
