Ta是一種標(biāo)準(zhǔn)的資源池模式
將資源的創(chuàng)建和銷毀都委托給資源池完成 用戶只需要關(guān)注取得資源之后自己的核心操作
提前預(yù)留活躍資源 在用戶需要的時(shí)候 能夠第一時(shí)間滿足用戶對(duì)資源的需求 從而讓用戶感受很好
假如一個(gè)線程的完整執(zhí)行時(shí)間 T 則T由三部分時(shí)間構(gòu)成
T = t1 + t2 + t3
t1 : 在操作系統(tǒng)當(dāng)中創(chuàng)建一個(gè)線程所消耗的時(shí)間
t2 : 執(zhí)行線程核心邏輯的時(shí)間 = run()
t3 : 在操作系統(tǒng)當(dāng)中銷毀一個(gè)線程所消耗的時(shí)間
如果run()當(dāng)中的操作非常簡(jiǎn)練 則t2所占T的比例就會(huì)很小
此時(shí)創(chuàng)建和銷毀所帶來(lái)的時(shí)間開(kāi)銷就會(huì)很大 為什么不引入可重用的資源池~
newCachedThreadPool 創(chuàng)建一個(gè)可緩存的線程池,如果線程池長(zhǎng)度超過(guò)處理需求,可靈活回收空閑線程,若無(wú)可回收,則新建線程
newFixedThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池,可控制線程大并發(fā)數(shù),超出的線程會(huì)在隊(duì)列中等待
newScheduledThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池,支持定時(shí)及周期性任務(wù)執(zhí)行
newSingleThreadExecutor 創(chuàng)建一個(gè)單線程化的線程池,它只會(huì)唯一的工作線程來(lái)執(zhí)行任務(wù)
import java.util.concurrent.*;//JUC
import java.util.*;
public class TestThreadPool{public static void main(String[] args)throws Exception{//白話版:端茶倒水的服務(wù)員 es = 職業(yè)介紹所.新建端茶倒水的服務(wù)員手持3杯水~
//學(xué)術(shù)版:執(zhí)行器服務(wù)的對(duì)象 es = 執(zhí)行器的工具類.新建一個(gè)修復(fù)后可以重用的線程池 當(dāng)中預(yù)留3個(gè)活躍線程
ExecutorService es = Executors.newFixedThreadPool(2);//固定個(gè)數(shù)的全職服務(wù)員
//Executors.newCachedThreadPool(); //60S 一分鐘 不固定個(gè)數(shù)的兼職服務(wù)員
//Executors.newSingleThreadExecutor();//形成程序當(dāng)中的"獨(dú)木橋"~
ThreadOne t1 = new ThreadOne();//新生
//白話版:找服務(wù)員要水喝 而不要自己去接水
//學(xué)術(shù)版:將線程任務(wù)t1 提交給執(zhí)行器服務(wù)
es.submit(t1);
ThreadTwo t2 = new ThreadTwo();
es.submit(t2);
ThreadThree t3 = new ThreadThree();
Futuref = es.submit(t3);
//我們可以根據(jù)自己的需求是否需要未來(lái)當(dāng)中的數(shù)據(jù)來(lái)決定是否調(diào)用get()
System.out.println("這里是不需要返回值的操作 例如喝杯水 講講課 順道等著勛勛回來(lái)~");
//get()之前是可以利用t3還在執(zhí)行的時(shí)候去做其它處理的~
String returnValue = f.get();//阻塞之后的操作 等待未來(lái)來(lái)到 等待勛勛買煙回來(lái)
System.out.println(returnValue + " 抽煙的操作 必須在買煙返回之后~");
//關(guān)閉執(zhí)行器服務(wù) = 讓服務(wù)員下班
Listbthld = es.shutdownNow();//es.shutdown();
}
}
class ThreadThree implements Callable{@Override
public String call()throws Exception{for(int i = 0;i<200;i++){ System.out.println("我是創(chuàng)建線程的第三種方式 3rd way ");
}
return "ETOAK VIVA";
}
}
class ThreadTwo implements Runnable{@Override
public void run(){for(int i = 0;i<200;i++){ System.out.println("我是創(chuàng)建線程的第二種方式 2nd way ");
}
}
}
class ThreadOne extends Thread{@Override
public void run(){for(int i = 0;i<200;i++){ System.out.println("我是創(chuàng)建線程的第一種方式 1st way ");
}
}
}
shutdown()與shutdownNow()的區(qū)別shutdown() : 不再接受新任務(wù)的提交 但是已經(jīng)提交的所有任務(wù)都要執(zhí)行完
shutdownNow() : 不再接受新任務(wù)的提交 已經(jīng)開(kāi)始執(zhí)行的能夠執(zhí)行完
但是還沒(méi)開(kāi)始執(zhí)行的 將直接退回給我們~
它彌補(bǔ)了原本Runnable接口當(dāng)中run()的兩大不足
run()被定義為void方法 執(zhí)行結(jié)束之后 線程無(wú)法返回?cái)?shù)據(jù)
run()沒(méi)有任何throws聲明 所以 逼迫程序員 線程體當(dāng)中try catch
如果將Callable接口的返回值對(duì)象設(shè)計(jì)為String那么調(diào)用Callable接口實(shí)現(xiàn)的線程的時(shí)必須等待Callable接口的Call()執(zhí)行結(jié)束
使用Future對(duì)象的話我們只有調(diào)用Future對(duì)象的get()方法才會(huì)阻塞
我們可以根據(jù)自己的需求是否需要未來(lái)當(dāng)中的數(shù)據(jù)來(lái)決定是否調(diào)用get()
你是否還在尋找穩(wěn)定的海外服務(wù)器提供商?創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級(jí)流量清洗系統(tǒng)配攻擊溯源,準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性,企業(yè)級(jí)服務(wù)器適合批量采購(gòu),新人活動(dòng)首月15元起,快前往官網(wǎng)查看詳情吧
網(wǎng)站標(biāo)題:Java中如何使用線程池-創(chuàng)新互聯(lián)
分享地址:http://www.rwnh.cn/article6/jdsig.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)頁(yè)設(shè)計(jì)公司、網(wǎng)站內(nèi)鏈、靜態(tài)網(wǎng)站、建站公司、網(wǎng)站收錄、服務(wù)器托管
聲明:本網(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í)需注明來(lái)源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容