執行緒池學習

三、 threadpoolexecutor

四、擴充套件執行緒池

總結在使用所執行緒進行開發時，為了避免系統頻繁地建立和銷毀執行緒，我們可以使用執行緒池技術。

executors類扮演著執行緒工廠的角色，使用該類的靜態方法可以獲取特點功能的執行緒池。

該方法返回固定執行緒數量的執行緒池。linkedblockingqueue

public
static
class
mytask
implements
runnable
catch
(interruptedexception e)
system.out.
println
(threadname+
"end");
}}public
static
void
main
(string[
] args)
system.out.
println
("main:"
+thread.
currentthread()
.getid()
+"end");
}

main:1start

1604731505456:thread id:11start

1604731505456:thread id:12start

1604731505456:thread id:12end

1604731506473:thread id:12start

1604731505456:thread id:11end

1604731506473:thread id:12end

main:1end

該方法返回乙個只有乙個執行緒的執行緒池。linkedblockingqueue

該方法返回乙個可根據實際情況調整執行緒數量的執行緒池。當開啟10個執行緒時，通過id可知，執行緒池中加有10個執行緒，該方法會根據cpu的資源占用自動調整執行緒池的大小。synchronousqueue

public
static
void
main
(string[
] args)
trycatch
(interruptedexception e)
}

該方法返回乙個scheduledexecutorservice物件，執行緒池大小為1。可以實現執行緒週期性執行和延遲執行。

該方法返回乙個scheduledexecutorservice物件，可指定執行緒池的執行緒數量。

/** command:任務 delay:延遲時間 timeunit:單位給定單元粒度的時間段 **/schedule (runnable command, long delay, timeunit unit) ;/** command:任務 initialdelay:初始延遲時間 period:週期的時間 unit:單位第一次：initialdelay+0*period 第二次：initialdelay+1*period ...**/ scheduleatfixedrate (runnable command, long initialdelay, long period,timeunit unit) /**command:任務 initialdelay:初始延遲時間 delay:延遲時間第一次：initialdelay 第二次：第一次的結束時間+delay **/schedulewithfixeddelay (runnable command, long initialdelay,

long delay,timeunit unit)

注意：任務遇到異常，後續的所有子任務都會停止排程。

以上介紹的執行緒池都是基於threadpoolexecutor類的封裝

threadpoolexecutor (int corepoolsize, //指定執行緒池中的執行緒數量 int maximumpoolsize, //指定執行緒池中的最大執行緒數 long keepalivetime, /** 當執行緒池中的執行緒數超過corepoolsize，多餘空閒執行緒的存活時間 **/timeunit unit, //時間單位 blockingqueue workqueue, //任務佇列 threadfactory threadfactory, //執行緒工廠 rejectedexecutionhandler handler)

//決絕策略

workqueue:提交但未執行的任務佇列。

handler:拒絕策略，當任務數量超過了系統的負載，就會使用到拒絕策略。

threadfactory:執行緒工廠是乙個介面。只定義了乙個用來建立執行緒的方法。

public inte***ce threadfactory

threadpoolexecutor 是乙個可以擴充套件的執行緒池。它提供了beforeexecutor()、afterexecutor()/terminated()三個介面用來對執行緒池進行控制。

public
class
mythreadpool
@override
public
void
run(
)catch
(interruptedexception e)}}
public
static
void
main
(string[
] args)
throws interruptedexception 
@override
protected
void
afterexecute
(runnable r, throwable t)
@override
protected
void
terminated()
};for(
int i=
0;i<
5;i++
) es.
shutdown()
;}}

越學習，自己越渺小…剛步入多執行緒的學習大軍，希望大家一起學習一起進步。

執行緒池學習

執行緒池學習

執行緒池學習

執行緒池學習

相關推薦