1.示例
package demoGradleOne;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class App {
public static void main(String[] args) {
ThreadPoolExecutor executorPool = new ThreadPoolExecutor(2, 4, 10, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(2), new RejectHandler());
for (int i = 0; i < 10; i++) {
Runnable worker = new ThreadWorker("" + i);
executorPool.execute(worker);
}
executorPool.shutdown(); // This will make the executor accept no new threads and finish all existing threads in the queue
while (!executorPool.isTerminated()) { // Wait until all threads are finish,and also you can use "executor.awaitTermination();" to wait
}
System.out.println("所有的活都干活了...");
}
}
ThreadWorker線程任務(wù)
package demoGradleOne;
public class ThreadWorker implements Runnable {
private String command;
public ThreadWorker(String s){
this.command=s;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+" 開始干活薪铜，編號 = "+ command);
processCommand(command);
System.out.println(Thread.currentThread().getName()+" 活干完了。");
}
private void processCommand(String command) {
try {
System.out.println("正在干, 編號：" + command + " 的活....");
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Override
public String toString(){
return this.command;
}
}
RejectHandler拒絕策略
package demoGradleOne;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
public class RejectHandler implements RejectedExecutionHandler{
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
System.out.println("編號： " + r.toString() + " 任務(wù)被拒絕啦恩溅，沒空搭理你...");
}
}
運(yùn)行結(jié)果：
pool-1-thread-2 開始干活，編號 = 1
pool-1-thread-4 開始干活谓娃，編號 = 5
編號： 6 任務(wù)被拒絕啦脚乡，沒空搭理你...
pool-1-thread-3 開始干活，編號 = 4
正在干, 編號：4 的活....
pool-1-thread-1 開始干活滨达，編號 = 0
編號： 7 任務(wù)被拒絕啦奶稠，沒空搭理你...
正在干, 編號：5 的活....
正在干, 編號：1 的活....
編號： 8 任務(wù)被拒絕啦，沒空搭理你...
正在干, 編號：0 的活....
編號： 9 任務(wù)被拒絕啦捡遍，沒空搭理你...
pool-1-thread-3 活干完了锌订。
pool-1-thread-2 活干完了。
pool-1-thread-2 開始干活画株，編號 = 2
正在干, 編號：2 的活....
pool-1-thread-1 活干完了辆飘。
pool-1-thread-4 活干完了。
pool-1-thread-3 開始干活谓传，編號 = 3
正在干, 編號：3 的活....
pool-1-thread-2 活干完了蜈项。
pool-1-thread-3 活干完了。
所有的活都干活了...
ThreadPoolExecutor Core and maximum pool sizes
ThreadPoolExecutor 會自動調(diào)整池的大小根據(jù)corePoolSize和maximumPoolSize的設(shè)置续挟。
當(dāng)一個任務(wù)通過execute方法提交后紧卒，如果當(dāng)前的線程數(shù)少于corePoolSize，新的線程將會被創(chuàng)建用于處理請求诗祸。即便是其他工作線程在閑置狀態(tài)跑芳。如果線程數(shù)大于corePoolSize但是少于maximumPoolSize,新的線程只有在queue滿的情況下，才會被創(chuàng)建直颅。通過設(shè)置corePoolSize和maxmumPoolSize成一樣的值博个，可以創(chuàng)建一個固定大小的線程池。通過設(shè)置maximumPoolSize成一個基本上無限的值际乘，比如Integer.MAX_VALUE坡倔，創(chuàng)建的線程池允許任意數(shù)量的并發(fā)任務(wù)，但是可以通過setCorePoolSize(int)和setMaximumPoolSize(int)動態(tài)的修改。
ThreadPoolExecutor keepAliveTime
如果池子當(dāng)前擁有超過corePoolSize個線程罪塔，多余的線程會被終止投蝉，如果他們已經(jīng)閑置的時長超過keepAliveTime.這提供了一種在不主動使用池時減少資源消耗的方法。如果池稍后變得更活躍征堪，則將構(gòu)造新線程瘩缆。該參數(shù)可以通過setKeepAliveTime(long, java.util.concurrent.TimeUnit)方法動態(tài)的改變。使用Long.MAX_VALUE TimeUnit.NANOSECONDS可以有效防止閑置線程佃蚜。默認(rèn)的庸娱，keep-alive策略只有在超過corePoolSize數(shù)據(jù)的線程時，才會被使用谐算。但是allowCoreThreadTimeOut(boolean)方法可以用于將這種超時控制策略應(yīng)用到核心線程上熟尉。只要keepAliveTime值為非零。
ThreadPoolExecutor Queuing
任何BlockingQueue都可用于傳輸和保留提交的任務(wù)洲脂。 此隊(duì)列的使用與池大小調(diào)整交互:
如果線程數(shù)少于corePoolSize個線程在運(yùn)行斤儿，Executor永遠(yuǎn)喜歡添加一個新的線程，而不是放到隊(duì)列中去恐锦。如果多個corePoolSize個線程在運(yùn)行往果，Executor將會把請求任務(wù)放到隊(duì)列中，而不是新添加線程一铅。如果一個請求任務(wù)無法添加到隊(duì)列中陕贮，新的線程將會創(chuàng)建在線程數(shù)少于maximumPoolSize。否則潘飘，任務(wù)將會被拒絕肮之。
隊(duì)列有三種常規(guī)策略:
- 直接交換. 默認(rèn)選擇為SynchronousQueue，它將任務(wù)交給線程而不另外保存它們福也。 在這里局骤，如果沒有可立即運(yùn)行的線程，則嘗試排隊(duì)任務(wù)將失敗暴凑，所以峦甩，一個新的線程將會被構(gòu)建。此策略在處理可能具有內(nèi)部依賴性的請求集時避免了鎖定现喳。直接切換通常需要無限制的maximumPoolSizes以避免拒絕新提交的任務(wù)凯傲。 這也將允許無限制的線程增長，當(dāng)任務(wù)到達(dá)快于任務(wù)執(zhí)行時嗦篱。
- 無界隊(duì)列. 使用無界隊(duì)列（例如冰单，沒有預(yù)定義容量的LinkedBlockingQueue）將導(dǎo)致新任務(wù)在所有corePoolSize線程忙時在隊(duì)列中等待。 因此灸促，只會創(chuàng)建corePoolSize線程诫欠。maximumPoolSize設(shè)置將不會有任何影響當(dāng)每個任務(wù)完全獨(dú)立于其他任務(wù)時涵卵，這可能是適當(dāng)?shù)模曰牡穑蝿?wù)不能影響其他的任務(wù)執(zhí)行轿偎。例如，在一個web服務(wù)器上被廓，雖然這種排隊(duì)方式可以用于平滑請求的瞬時突發(fā)坏晦，但是也存在線程無限制增長的可能性，在任務(wù)到達(dá)比任務(wù)執(zhí)行快的情況下嫁乘。
- 有界隊(duì)列. 有界隊(duì)列（例如昆婿，ArrayBlockingQueue）在與有值maximumPoolSizes一起使用時有助于防止資源耗盡，但可能更難以調(diào)整和控制蜓斧，隊(duì)列大小和最大池大小可以相互交換：使用大型隊(duì)列和小型池最小化CPU使用率仓蛆，OS資源和上下文切換開銷，但可能導(dǎo)致人為的低吞吐量挎春。 如果任務(wù)經(jīng)常阻塞（例如多律，如果它們是I / O綁定的），系統(tǒng)可能能夠?yàn)槟峁┍饶试S的更多線程的時間搂蜓。 使用小隊(duì)列通常需要更大的池大小，這會使CPU更加繁忙辽装，但可能會遇到不可接受的調(diào)度開銷帮碰，這也會降低吞吐量。
