??ThreadPoolExecutor如何在java中使用

本篇文章為大家展示了 ThreadPoolExecutor如何在java中使用，內(nèi)容簡明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過這篇文章的詳細(xì)介紹希望你能有所收獲。

網(wǎng)站建設(shè)哪家好，找創(chuàng)新互聯(lián)！專注于網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、成都小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了察哈爾右翼后免費(fèi)建站歡迎大家使用！

java ThreadPoolExecutor

前言：

在項(xiàng)目中如果使用發(fā)短信這個(gè)功能，一般會(huì)把發(fā)短信這個(gè)動(dòng)作變成異步的，因?yàn)榇蟛糠智闆r下，短信到底是發(fā)送成功或者失敗，都不能影響主流程。當(dāng)然像發(fā)送MQ消息等操作也是可以封裝成異步操作的。

使用基本的New Thread

如果想一個(gè)操作變成異步的，可以直接new thread，然后在run方法中實(shí)現(xiàn)業(yè)務(wù)操作即可。例如：

 new Thread(new Runnable() {
    public void run() {
      //發(fā)短信、發(fā)MQ消息等
    }
 });

但是這種方式有幾個(gè)缺點(diǎn)。

1.每次都會(huì)new一個(gè)線程，執(zhí)行完后銷毀，不能復(fù)用；

2.如果系統(tǒng)的并發(fā)量剛好比較大，需要大量線程，那么這種每次new的方式會(huì)搶資源的。

ThreadPoolExecutor

我們可以使用jdk1.5中的ThreadPoolExecutor來封裝異步操作。ThreadPoolExecutor的好處是可以做到線程復(fù)用，并且使用盡量少的線程去執(zhí)行更多的任務(wù)，效率和性能都相當(dāng)不錯(cuò)。demo代碼如下：

public class ThreadPool {
  private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(8, 12, 30,
      TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(50000), new ThreadPoolExecutor.AbortPolicy());

  public static ThreadPoolExecutor getThreadPool() {
    return threadPool;
  }
}

參數(shù)介紹

public ThreadPoolExecutor(int corePoolSize,
               int maximumPoolSize,
               long keepAliveTime,
               TimeUnit unit,
               BlockingQueue<Runnable> workQueue,
               RejectedExecutionHandler handler) {

 }

corePoolSize：當(dāng)workQueue隊(duì)列中的元素還未到達(dá)最大值時(shí)，corePoolSize表示的池中線程數(shù)量的最大值；
maximumPoolSize：線程池中允許的最大線程數(shù)；
keepAliveTime：當(dāng)前池中的線程數(shù)如果超過了corePoolSize，那么超出那些線程如果空閑太久了，應(yīng)該需要銷毀的。keepAliveTime就是的是這些線程的最大空閑時(shí)間；
unit：keepAliveTime的時(shí)間單位；
workQueue：當(dāng)池中線程數(shù)的數(shù)量已經(jīng)達(dá)到了corePoolSize，那么如果請(qǐng)求還繼續(xù)過來，會(huì)把請(qǐng)求對(duì)應(yīng)的task放入隊(duì)列中；
handler：當(dāng)workQueue滿了，池中的線程數(shù)又達(dá)到了maximumPoolSize，這個(gè)時(shí)候已經(jīng)沒有多余的資源處理請(qǐng)求了，需要RejectedExecutionHandler 來處理。拒絕處理或者丟棄任務(wù)等等。

執(zhí)行過程

當(dāng)沒有請(qǐng)求時(shí)，線程池中沒有任何線程；

當(dāng)有請(qǐng)求時(shí)，創(chuàng)建線程，一直到池中的線程數(shù)等于corePoolSize；

如果請(qǐng)求太多，需要更多的線程來處理的話，ThreadPoolExecutor選擇把請(qǐng)求放入隊(duì)列中，暫時(shí)不新建線程；

如果workQueue也滿了，ThreadPoolExecutor會(huì)繼續(xù)創(chuàng)建線程，直到線程數(shù)量跟maximumPoolSize相等；

線程數(shù)達(dá)到maximumPoolSize了，同時(shí)workQueue也慢了，就只能把請(qǐng)求丟給RejectedExecutionHandler 來處理。

備注

使用ThreadPoolExecutor時(shí)，需要根據(jù)自己的業(yè)務(wù)情況，適當(dāng)?shù)闹付▍?shù)值的大小。

上述內(nèi)容就是 ThreadPoolExecutor如何在java中使用，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)頁標(biāo)題：??ThreadPoolExecutor如何在java中使用
URL網(wǎng)址：http://muchs.cn/article0/ipisio.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)公司、網(wǎng)站改版、品牌網(wǎng)站建設(shè)、微信公眾號(hào)、電子商務(wù)、網(wǎng)站收錄

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容