Java線程池

一垢乙、線程池簡(jiǎn)介

線程的使用在Java中占有重要的地位,尤其是在執(zhí)行耗時(shí)操作(Java網(wǎng)絡(luò)編程)和異步訪問(SWT中更新界面元素)時(shí)顯得格外重要。線程雖然方便置逻,但當(dāng)需要同時(shí)執(zhí)行大量的線程操作和特定的異步訪問時(shí),通過為每一個(gè)新任務(wù)單獨(dú)新開線程就會(huì)造成大量的資源浪費(fèi)输枯,而且對(duì)同一類任務(wù)的多線程不能做到統(tǒng)一的管理议泵,所以就有了多線程的技術(shù)。
  多線程技術(shù)主要解決處理器單元內(nèi)多個(gè)線程執(zhí)行的問題桃熄,它可以顯著減少處理器單元的閑置時(shí)間先口,增加處理器單元的吞吐能力。

二瞳收、Java線程池

線程池的作用:

1碉京、限制系統(tǒng)中執(zhí)行線程的數(shù)量

線程池能夠基于當(dāng)前系統(tǒng)運(yùn)行環(huán)境,通過自動(dòng)或者手動(dòng)的方式調(diào)整系統(tǒng)中運(yùn)行線程的數(shù)量螟深,從而達(dá)到節(jié)約系統(tǒng)資源的目的谐宙。設(shè)置線程池的數(shù)量可以防止程序無(wú)限制的開啟線程而造成的資源浪費(fèi),任務(wù)少的時(shí)候放入線程池中執(zhí)行界弧,任務(wù)超過線程池?cái)?shù)量限制時(shí)卧惜,排隊(duì)等待。一個(gè)任務(wù)執(zhí)行完畢后會(huì)從排隊(duì)任務(wù)重取出任務(wù)放入線程池中執(zhí)行夹纫,也就是說(shuō)當(dāng)一個(gè)新任務(wù)到來(lái)時(shí)咽瓷,如果線程池未滿則執(zhí)行新任務(wù),如果線程池已滿就需進(jìn)入等待隊(duì)列直到有空閑的線程池資源舰讹。

2茅姜、對(duì)線程的統(tǒng)一管理

開發(fā)過程中會(huì)對(duì)多個(gè)相同或者相似的任務(wù)統(tǒng)一處理的情況,線程池可以對(duì)線程統(tǒng)一管理月匣,比如:?jiǎn)拘丫€程池中所有的線程钻洒,銷毀所有的線程。

Java內(nèi)置的線程池:

Java線程池的頂級(jí)接口為Executor锄开,但一般使用較多的接口為ExecutorService素标,ExecutorService類中含有更多的對(duì)線程池的操作。

方法 描述
isShutDown() 如果此執(zhí)行程序已關(guān)閉萍悴,則返回 true头遭。
isTerminated() 如果關(guān)閉后所有任務(wù)都已完成,則返回 true癣诱。
shutdown() 啟動(dòng)一次順序關(guān)閉计维,執(zhí)行以前提交的任務(wù),但不接受新任務(wù)撕予。
shutdownNow() 試圖停止所有正在執(zhí)行的活動(dòng)任務(wù)鲫惶,暫停處理正在等待的任務(wù),并返回等待執(zhí)行的任務(wù)列表实抡。
submit(task) 提交一個(gè) Runnable 任務(wù)用于執(zhí)行欠母,并返回一個(gè)表示該任務(wù)的 Future欢策。

ExecutorService類中常用的方法:

方法 描述
isShutDown() 如果此執(zhí)行程序已關(guān)閉,則返回 true赏淌。
isTerminated() 如果關(guān)閉后所有任務(wù)都已完成猬腰,則返回 true。
shutdown() 啟動(dòng)一次順序關(guān)閉猜敢,執(zhí)行以前提交的任務(wù)姑荷,但不接受新任務(wù)。
shutdownNow() 試圖停止所有正在執(zhí)行的活動(dòng)任務(wù)缩擂,暫停處理正在等待的任務(wù)鼠冕,并返回等待執(zhí)行的任務(wù)列表。
submit(task) 提交一個(gè) Runnable 任務(wù)用于執(zhí)行胯盯,并返回一個(gè)表示該任務(wù)的 Future懈费。

為方便創(chuàng)建線程池Executors類中提供一些靜態(tài)方法,用于快速創(chuàng)建線程池博脑。

  1. newCachedThreadPool
      創(chuàng)建一個(gè)可緩存線程池憎乙,如果線程池大小超過處理需要,可靈活回收空閑線程叉趣,若無(wú)可回收線程泞边,則創(chuàng)建線程。此線程池不會(huì)對(duì)線程池大小限制(但可以指定初始線程池的大辛粕肌)阵谚,線程池大小完全依賴于JVM空間的限制。
  2. **newFixedThreadPool **
      創(chuàng)建一個(gè)定長(zhǎng)線程池烟具,可控制線程最大并發(fā)數(shù)梢什,線程池一旦達(dá)到最大限制,超出的線程會(huì)在隊(duì)列中等待朝聋。
  3. **newScheduledThreadPool **
      創(chuàng)建一個(gè)定長(zhǎng)線程池嗡午,它可安排在給定延遲后運(yùn)行命令或者定期地執(zhí)行。
  4. **newSingleThreadExecutor **
      創(chuàng)建一個(gè)單線程化的線程池冀痕,它只會(huì)用唯一的工作線程來(lái)執(zhí)行任務(wù)荔睹,保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行。
      
    newCachedThreadPool測(cè)試代碼:
public class NewCachedThreadPoolTest {
    public static void main(String[] args) {
        ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            final int index = i;
            try {
                Thread.sleep(index * 1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            cachedThreadPool.execute(new Runnable() {
                public void run() {
                    System.out.println(index);
                }
            });
        }
    }
}

當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成金度,會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程应媚,而不用每次新建線程。
  
newFixedThreadPool 測(cè)試代碼:

public class FixedThreadPoolTest {
    public static void main(String[] args) {
        //創(chuàng)建一個(gè)可重用固定線程數(shù)的線程池
        ExecutorService pool = Executors.newFixedThreadPool(2);
        //創(chuàng)建實(shí)現(xiàn)了Runnable接口對(duì)象猜极,Thread對(duì)象當(dāng)然也實(shí)現(xiàn)了Runnable接口
        Thread t1 = new MyThread();
        Thread t2 = new MyThread();
        Thread t3 = new MyThread();
        Thread t4 = new MyThread();
        Thread t5 = new MyThread();
        //將線程放入池中進(jìn)行執(zhí)行
        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        //關(guān)閉線程池
        pool.shutdown();
    }
}

輸出結(jié)果:

pool-1-thread-1正在執(zhí)行。消玄。跟伏。
pool-1-thread-2正在執(zhí)行丢胚。。受扳。
pool-1-thread-1正在執(zhí)行携龟。。勘高。
pool-1-thread-2正在執(zhí)行峡蟋。。华望。
pool-1-thread-1正在執(zhí)行蕊蝗。。赖舟。

newScheduledThreadPool 測(cè)試代碼:


public class ScheduledThreadPoolExecutorTest {
    public static void main(String[] args) {
        ScheduledThreadPoolExecutor exec = new ScheduledThreadPoolExecutor(1);
        exec.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                System.out.println("================");
            }
        }, 1000, 5000, TimeUnit.MILLISECONDS);
        exec.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                System.out.println(System.nanoTime());
            }
        }, 1000, 2000, TimeUnit.MILLISECONDS);
    }
}

輸出結(jié)果:


================
41070644908191
41072644693809
41074645495462
================
41076644808412
41078644896218
================
41080645104328
41082645027356
41084645111170
================
41086645135117
41088645164196

newScheduledThreadPool 測(cè)試代碼:


public class SingleThreadExecutorTest
 {
    public static void main(String[] args) {

        ExecutorService pool = Executors.newSingleThreadExecutor();

        Thread t1 = new MyThread();
        Thread t2 = new MyThread();
        Thread t3 = new MyThread();
        Thread t4 = new MyThread();
        Thread t5 = new MyThread();

        pool.execute(t1);
        pool.execute(t2);
        pool.execute(t3);
        pool.execute(t4);
        pool.execute(t5);
        // 關(guān)閉線程池
        pool.shutdown();
    }
}

輸出結(jié)果:

pool-1-thread-1正在執(zhí)行蓬戚。。宾抓。
pool-1-thread-1正在執(zhí)行子漩。。石洗。
pool-1-thread-1正在執(zhí)行幢泼。。讲衫。
pool-1-thread-1正在執(zhí)行旭绒。。焦人。
pool-1-thread-1正在執(zhí)行挥吵。。花椭。

每種線程池都會(huì)有特定的使用場(chǎng)景忽匈,上述四種線程池能滿足大部分的需求。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末矿辽,一起剝皮案震驚了整個(gè)濱河市丹允,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌袋倔,老刑警劉巖雕蔽,帶你破解...
    沈念sama閱讀 211,948評(píng)論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異宾娜,居然都是意外死亡批狐,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,371評(píng)論 3 385
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)嚣艇,“玉大人承冰,你說(shuō)我怎么就攤上這事∈沉悖” “怎么了困乒?”我有些...
    開封第一講書人閱讀 157,490評(píng)論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)贰谣。 經(jīng)常有香客問我娜搂,道長(zhǎng)蟆融,這世上最難降的妖魔是什么风范? 我笑而不...
    開封第一講書人閱讀 56,521評(píng)論 1 284
  • 正文 為了忘掉前任,我火速辦了婚禮怀各,結(jié)果婚禮上频伤,老公的妹妹穿的比我還像新娘恳谎。我一直安慰自己,他們只是感情好憋肖,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,627評(píng)論 6 386
  • 文/花漫 我一把揭開白布因痛。 她就那樣靜靜地躺著,像睡著了一般岸更。 火紅的嫁衣襯著肌膚如雪鸵膏。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,842評(píng)論 1 290
  • 那天怎炊,我揣著相機(jī)與錄音谭企,去河邊找鬼。 笑死评肆,一個(gè)胖子當(dāng)著我的面吹牛债查,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播瓜挽,決...
    沈念sama閱讀 38,997評(píng)論 3 408
  • 文/蒼蘭香墨 我猛地睜開眼盹廷,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了久橙?” 一聲冷哼從身側(cè)響起俄占,我...
    開封第一講書人閱讀 37,741評(píng)論 0 268
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎淆衷,沒想到半個(gè)月后缸榄,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 44,203評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡祝拯,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,534評(píng)論 2 327
  • 正文 我和宋清朗相戀三年甚带,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 38,673評(píng)論 1 341
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡欲低,死狀恐怖辕宏,靈堂內(nèi)的尸體忽然破棺而出畜晰,到底是詐尸還是另有隱情砾莱,我是刑警寧澤,帶...
    沈念sama閱讀 34,339評(píng)論 4 330
  • 正文 年R本政府宣布凄鼻,位于F島的核電站腊瑟,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏块蚌。R本人自食惡果不足惜闰非,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,955評(píng)論 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望峭范。 院中可真熱鬧财松,春花似錦、人聲如沸纱控。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,770評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)甜害。三九已至舶掖,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間尔店,已是汗流浹背眨攘。 一陣腳步聲響...
    開封第一講書人閱讀 32,000評(píng)論 1 266
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留嚣州,地道東北人鲫售。 一個(gè)月前我還...
    沈念sama閱讀 46,394評(píng)論 2 360
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像该肴,于是被迫代替她去往敵國(guó)和親情竹。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,562評(píng)論 2 349

推薦閱讀更多精彩內(nèi)容