Java 5線程池使用
線程池是Java5提供的一個新技術(shù),方便我們快速簡潔的定義線程池。包括如下:
諸如 Web 服務(wù)器、數(shù)據(jù)庫服務(wù)器、文件服務(wù)器或郵件服務(wù)器之類的許多服務(wù)器應(yīng)用程序都面向處理來自某些遠(yuǎn)程來源的大量短小的任務(wù)。請求以某種方式到達(dá)服務(wù)器,這種方式可能是通過網(wǎng)絡(luò)協(xié)議(例如 HTTP、FTP 或 POP)、通過 JMS 隊列或者可能通過輪詢數(shù)據(jù)庫。不管請求如何到達(dá),服務(wù)器應(yīng)用程序中經(jīng)常出現(xiàn)的情況是:單個任務(wù)處理的時間很短而請求的數(shù)目卻是巨大的。
構(gòu)建服務(wù)器應(yīng)用程序的一個過于簡單的模型應(yīng)該是:每當(dāng)一個請求到達(dá)就創(chuàng)建一個新線程,然后在新線程中為請求服務(wù)。實(shí)際上,對于原型開發(fā)這種方法工作得很好,但如果試圖部署以這種方式運(yùn)行的服務(wù)器應(yīng)用程序,那么這種方法的嚴(yán)重不足就很明顯。每個請求對應(yīng)一個線程(thread-per-request)方法的不足之一是:為每個請求創(chuàng)建一個新線程的開銷很大;為每個請求創(chuàng)建新線程的服務(wù)器在創(chuàng)建和銷毀線程上花費(fèi)的時間和消耗的系統(tǒng)資源要比花在處理實(shí)際的用戶請求的時間和資源更多。
除了創(chuàng)建和銷毀線程的開銷之外,活動的線程也消耗系統(tǒng)資源。在一個 JVM 里創(chuàng)建太多的線程可能會導(dǎo)致系統(tǒng)由于過度消耗內(nèi)存而用完內(nèi)存或“切換過度”。為了防止資源不足,服務(wù)器應(yīng)用程序需要一些辦法來限制任何給定時刻處理的請求數(shù)目。
線程池為線程生命周期開銷問題和資源不足問題提供了解決方案。通過對多個任務(wù)重用線程,線程創(chuàng)建的開銷被分?jǐn)偟搅硕鄠€任務(wù)上。其好處是,因?yàn)樵谡埱蟮竭_(dá)時線程已經(jīng)存在,所以無意中也消除了線程創(chuàng)建所帶來的延遲。這樣,就可以立即為請求服務(wù),使應(yīng)用程序響應(yīng)更快。而且,通過適當(dāng)?shù)卣{(diào)整線程池中的線程數(shù)目,也就是當(dāng)請求的數(shù)目超過某個閾值時,就強(qiáng)制其它任何新到的請求一直等待,直到獲得一個線程來處理為止,從而可以防止資源不足。
Java5提供以下線程池:
緩存線程池(newCachedThreadPool),可以創(chuàng)建任意個線程,每個任務(wù)過來后都會創(chuàng)建一個線程,用于任務(wù)少,或執(zhí)行時間短的任務(wù),例如我們創(chuàng)建十個任務(wù),那么緩沖線程池將會創(chuàng)建十個線程來執(zhí)行。如下代碼:
- ExecutorService threadPool = Executors.newCachedThreadPool();
- for(int i=1; i<=10; i++){
- final int taskId = i;
- threadPool.execute(new Runnable(){
- public void run() {
- for(int i=1; i<=10; i++){
- System.out.println(Thread.currentThread().getName() + " is looping of " + i + " the task is " + taskId);
- try {
- Thread.sleep(20);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- }
- });
- }
- System.out.println("add all of 10 task");
- threadPool.shutdown();
固定數(shù)量線程池(newFixedThreadPool)允許我們創(chuàng)建固定線程數(shù)量的線程池,如果任務(wù)數(shù)大于線程池中線程的數(shù)量,那么任務(wù)將等待,如下代碼:
- ExecutorService threadPool = Executors.newFixedThreadPool(3);
- for(int i=1; i<=10; i++){
- final int taskId = i;
- threadPool.execute(new Runnable(){
- public void run() {
- for(int i=1; i<=10; i++){
- System.out.println(Thread.currentThread().getName() + " is looping of " + i + " the task is " + taskId);
- try {
- Thread.sleep(20);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- }
- });
- }
- System.out.println("add all of 10 task");
- threadPool.shutdown();
如何實(shí)現(xiàn)線程掛掉后重新啟動(創(chuàng)建單一的線程池)newSingleThreadExecutor(),這樣線程池中只會有一個線程工作,當(dāng)線程失敗后會重新創(chuàng)建一個線程將失敗的線程替換掉。
定時器線程池(scheduleAtFixedRate)與定時器很類似,可以指定線程池中線程在多長時間后執(zhí)行,以及每個多長時間執(zhí)行一次,代碼如下,可以模擬讓炸彈在6s后爆炸,并且每個2s炸一次:
- Executors.newScheduledThreadPool(3).scheduleAtFixedRate(
- // .schedule(
- new Runnable(){
- public void run() {
- System.out.println("boming");
- }
- }, 6, 2, TimeUnit.SECONDS);
- }
大家可以執(zhí)行代碼測試。
原文鏈接:http://blog.csdn.net/lb85858585/article/details/7288983
【編輯推薦】