在java項(xiàng)目中使用線程池如何實(shí)現(xiàn)獲取運(yùn)行線程數(shù)并控制線程啟動(dòng)速度

發(fā)布時(shí)間：2020-11-20 16:34:44 來源：億速云閱讀：279 作者：Leah 欄目：編程語言

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)在java項(xiàng)目中使用線程池如何實(shí)現(xiàn)獲取運(yùn)行線程數(shù)并控制線程啟動(dòng)速度，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

在java里，我們可以使用Executors.newFixedThreadPool 來創(chuàng)建線程池，然后就可以不停的創(chuàng)建新任務(wù)，并用線程池來執(zhí)行了。

在提交任務(wù)時(shí)，如果線程池已經(jīng)被占滿，任務(wù)會(huì)進(jìn)到一個(gè)隊(duì)列里等待執(zhí)行。

這種機(jī)制在一些特定情況下會(huì)有些問題。今天我就遇到一種情況：創(chuàng)建線程比線程執(zhí)行的速度要快的多，而且單個(gè)線程占用的內(nèi)存又多，所以很快內(nèi)存就爆了。

想了一個(gè)辦法，就是在提交任務(wù)之前，先檢查目前正在執(zhí)行的線程數(shù)目，只有沒把線程池占滿的時(shí)候在去提交任務(wù)。

代碼很簡單：

int threadCount = ((ThreadPoolExecutor)executor).getActiveCount();
//              System.out.println("running : " + threadCount);
              while (threadCount == POOL_SIZE) {
                TimeUnit.MILLISECONDS.sleep(1);
                threadCount = ((ThreadPoolExecutor)executor).getActiveCount();
//                System.out.println("running : " + threadCount);
              }

              executor.execute

上述就是小編為大家分享的在java項(xiàng)目中使用線程池如何實(shí)現(xiàn)獲取運(yùn)行線程數(shù)并控制線程啟動(dòng)速度了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。

向AI問一下細(xì)節(jié)

在java項(xiàng)目中使用線程池如何實(shí)現(xiàn)獲取運(yùn)行線程數(shù)并控制線程啟動(dòng)速度

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽