建站
咨詢(xún)
售后
建站咨詢(xún)
新聞中心
Ta是一種標(biāo)準(zhǔn)的資源池模式
將資源的創(chuàng)建和銷(xiāo)毀都委托給資源池完成 用戶(hù)只需要關(guān)注取得資源之后自己的核心操作
提前預(yù)留活躍資源 在用戶(hù)需要的時(shí)候 能夠第一時(shí)間滿(mǎn)足用戶(hù)對(duì)資源的需求 從而讓用戶(hù)感受很好
假如一個(gè)線(xiàn)程的完整執(zhí)行時(shí)間 T 則T由三部分時(shí)間構(gòu)成
T = t1 + t2 + t3
t1 : 在操作系統(tǒng)當(dāng)中創(chuàng)建一個(gè)線(xiàn)程所消耗的時(shí)間
t2 : 執(zhí)行線(xiàn)程核心邏輯的時(shí)間 = run()
t3 : 在操作系統(tǒng)當(dāng)中銷(xiāo)毀一個(gè)線(xiàn)程所消耗的時(shí)間
如果run()當(dāng)中的操作非常簡(jiǎn)練 則t2所占T的比例就會(huì)很小
此時(shí)創(chuàng)建和銷(xiāo)毀所帶來(lái)的時(shí)間開(kāi)銷(xiāo)就會(huì)很大 為什么不引入可重用的資源池~
newCachedThreadPool 創(chuàng)建一個(gè)可緩存的線(xiàn)程池，如果線(xiàn)程池長(zhǎng)度超過(guò)處理需求，可靈活回收空閑線(xiàn)程，若無(wú)可回收，則新建線(xiàn)程
newFixedThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線(xiàn)程池，可控制線(xiàn)程大并發(fā)數(shù)，超出的線(xiàn)程會(huì)在隊(duì)列中等待
newScheduledThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線(xiàn)程池，支持定時(shí)及周期性任務(wù)執(zhí)行
newSingleThreadExecutor 創(chuàng)建一個(gè)單線(xiàn)程化的線(xiàn)程池，它只會(huì)唯一的工作線(xiàn)程來(lái)執(zhí)行任務(wù)
import java.util.concurrent.*;//JUC
import java.util.*;
public class TestThreadPool{public static void main(String[] args)throws Exception{//白話(huà)版：端茶倒水的服務(wù)員 es = 職業(yè)介紹所.新建端茶倒水的服務(wù)員手持3杯水~
//學(xué)術(shù)版：執(zhí)行器服務(wù)的對(duì)象 es = 執(zhí)行器的工具類(lèi).新建一個(gè)修復(fù)后可以重用的線(xiàn)程池 當(dāng)中預(yù)留3個(gè)活躍線(xiàn)程
ExecutorService es = Executors.newFixedThreadPool(2);//固定個(gè)數(shù)的全職服務(wù)員
//Executors.newCachedThreadPool(); //60S 一分鐘 不固定個(gè)數(shù)的兼職服務(wù)員
//Executors.newSingleThreadExecutor();//形成程序當(dāng)中的"獨(dú)木橋"~
ThreadOne t1 = new ThreadOne();//新生
//白話(huà)版：找服務(wù)員要水喝 而不要自己去接水
//學(xué)術(shù)版：將線(xiàn)程任務(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)到 等待勛勛買(mǎi)煙回來(lái)
System.out.println(returnValue + " 抽煙的操作 必須在買(mǎi)煙返回之后~");
//關(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)建線(xiàn)程的第三種方式 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)建線(xiàn)程的第二種方式 2nd way ");
}
}
}
class ThreadOne extends Thread{@Override
public void run(){for(int i = 0;i<200;i++){ System.out.println("我是創(chuàng)建線(xiàn)程的第一種方式 1st way ");
}
}
}
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é)束之后 線(xiàn)程無(wú)法返回?cái)?shù)據(jù)
run()沒(méi)有任何throws聲明 所以 逼迫程序員 線(xiàn)程體當(dāng)中try catch
如果將Callable接口的返回值對(duì)象設(shè)計(jì)為String那么調(diào)用Callable接口實(shí)現(xiàn)的線(xiàn)程的時(shí)必須等待Callable接口的Call()執(zhí)行結(jié)束
使用Future對(duì)象的話(huà)我們只有調(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)頁(yè)標(biāo)題：Java中如何使用線(xiàn)程池-創(chuàng)新互聯(lián)
本文網(wǎng)址：http://www.dlmjj.cn/article/jdsig.html
