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)建和銷毀所帶來的時(shí)間開銷就會(huì)很大 為什么不引入可重用的資源池~
newCachedThreadPool 創(chuàng)建一個(gè)可緩存的線程池，如果線程池長(zhǎng)度超過處理需求，可靈活回收空閑線程，若無可回收，則新建線程
newFixedThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池，可控制線程大并發(fā)數(shù)，超出的線程會(huì)在隊(duì)列中等待
newScheduledThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池，支持定時(shí)及周期性任務(wù)執(zhí)行
newSingleThreadExecutor 創(chuàng)建一個(gè)單線程化的線程池，它只會(huì)唯一的工作線程來執(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ù)自己的需求是否需要未來當(dāng)中的數(shù)據(jù)來決定是否調(diào)用get()
System.out.println("這里是不需要返回值的操作 例如喝杯水 講講課 順道等著勛勛回來~");
//get()之前是可以利用t3還在執(zhí)行的時(shí)候去做其它處理的~
String returnValue = f.get();//阻塞之后的操作 等待未來來到 等待勛勛買煙回來
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() : 不再接受新任務(wù)的提交 但是已經(jīng)提交的所有任務(wù)都要執(zhí)行完
shutdownNow() : 不再接受新任務(wù)的提交 已經(jīng)開始執(zhí)行的能夠執(zhí)行完
但是還沒開始執(zhí)行的 將直接退回給我們~
它彌補(bǔ)了原本Runnable接口當(dāng)中run()的兩大不足
run()被定義為void方法 執(zhí)行結(jié)束之后 線程無法返回?cái)?shù)據(jù)
run()沒有任何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ù)自己的需求是否需要未來當(dāng)中的數(shù)據(jù)來決定是否調(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)查看詳情吧
