Java詳解使用線程池處理任務(wù)方法

第Java詳解使用線程池處理任務(wù)方法不使用線程池的問題：

如果用戶每發(fā)起一個請求，后臺就創(chuàng)建一個新線程來處理，下次新任務(wù)來了又要創(chuàng)建新線程，而創(chuàng)建新線程的開銷是很大的，這樣會嚴(yán)重影響系統(tǒng)的性能。

線程池常見面試題：

1、臨時線程什么時候創(chuàng)建？

新任務(wù)提交時發(fā)現(xiàn)核心線程都在忙，任務(wù)隊列也滿了，并且還可以創(chuàng)建臨時線程，此時才會創(chuàng)建臨時線程。

2、什么時候會開始拒絕任務(wù)？

核心線程和臨時線程都在忙，任務(wù)隊列也滿了，新的任務(wù)過來的時候才會開始任務(wù)拒絕。

1、線程池處理Runnable任務(wù)

importjava.util.concurrent.*;

publicclass多線程_5線程池處理Runnable任務(wù){(diào)

publicstaticvoidmain(String[]args){

//線程池處理Runnable任務(wù)

//創(chuàng)建線程池對象

publicThreadPoolExecutor(intcorePoolSize,//核心線程數(shù)量

intmaximumPoolSize,//線程池可支持的最大線程數(shù)量

longkeepAliveTime,//臨時線程的最大存活時間

TimeUnitunit,//指定存活時間的單位（秒，分等）

BlockingQueueRunnableworkQueue,//指定任務(wù)隊列

ThreadFactorythreadFactory,//指定用哪個線程工廠創(chuàng)建線程

RejectedExecutionHandlerhandler)//指定線程忙，任務(wù)滿了的時候，新任務(wù)來了怎么辦

ExecutorServicepool=newThreadPoolExecutor(3,5,

6,TimeUnit.SECONDS,newArrayBlockingQueue(5),

Executors.defaultThreadFactory(),newThreadPoolExecutor.AbortPolicy());

//給任務(wù)線程池處理

Runnabler=newMyExe();

//三個核心線程

pool.execute(r);

pool.execute(r);

pool.execute(r);

//五個任務(wù)隊列（不創(chuàng)建臨時線程時，會發(fā)現(xiàn)只有三個線程，即核心線程量）

pool.execute(r);

pool.execute(r);

pool.execute(r);

pool.execute(r);

pool.execute(r);

//創(chuàng)建臨時線程(五個線程，即最大線程量)

pool.execute(r);

pool.execute(r);

//不創(chuàng)建，拒絕策略被觸發(fā)

//pool.execute(r);

//關(guān)閉線程池（開發(fā)中一般不會使用）

//pool.shutdownNow();//立即關(guān)閉，即使任務(wù)沒有執(zhí)行完畢。會丟失任務(wù)的！

//pool.shutdown();//會等待任務(wù)全部執(zhí)行完畢后再關(guān)閉（建議使用）

classMyExeimplementsRunnable{

publicvoidrun(){

for(inti=1;ii++){

System.out.println(Thread.currentThread().getName()+"正在執(zhí)行："+i+"次");

//因為當(dāng)前案例任務(wù)太簡單，我們需要創(chuàng)建臨時隊列需要讓三個核心線程忙，五個任務(wù)隊列排滿,所以讓線程休眠以增加任務(wù)時間

try{

System.out.println(Thread.currentThread().getName()+"任務(wù)與線程綁定，線程進(jìn)入了休眠");

Thread.sleep(1000000);

}catch(Exceptione){

e.printStackTrace();

}

2、線程池處理Callable任務(wù)

importjava.util.concurrent.*;

publicclass多線程_5線程池處理Callable任務(wù){(diào)

publicstaticvoidmain(String[]args)throwsException{

//線程池處理Callable任務(wù)

//創(chuàng)建線程池對象

publicThreadPoolExecutor(intcorePoolSize,//核心線程數(shù)量

intmaximumPoolSize,//線程池可支持的最大線程數(shù)量

longkeepAliveTime,//臨時線程的最大存活時間

TimeUnitunit,//指定存活時間的單位（秒，分等）

BlockingQueueRunnableworkQueue,//指定任務(wù)隊列

ThreadFactorythreadFactory,//指定用哪個線程工廠創(chuàng)建線程

RejectedExecutionHandlerhandler)//指定線程忙，任務(wù)滿了的時候，新任務(wù)來了怎么辦

ExecutorServicepool=newThreadPoolExecutor(3,5,

6,TimeUnit.SECONDS,newArrayBlockingQueue(5),

Executors.defaultThreadFactory(),newThreadPoolExecutor.AbortPolicy());

//給任務(wù)線程池處理

//Callablec=newMyCallable2(100);

//pool.submit(c);

FutureStringf1=pool.submit(newMyCallable2(100));

FutureStringf2=pool.submit(newMyCallable2(200));

FutureStringf3=pool.submit(newMyCallable2(300));

FutureStringf4=pool.submit(newMyCallable2(400));

FutureStringf5=pool.submit(newMyCallable2(500));

//Stringstr=f1.get();

//System.out.println(str);

System.out.println(f1.get());

System.out.println(f2.get());

System.out.println(f3.get());

System.out.println(f4.get());

System.out.println(f5.get());

classMyCallable2implementsCallableString{

//v(泛型)

privateintn;

publicMyCallable2(intn){

this.n=n;

//重寫call方法

//案例：加法

pub