Java手動配置線程池過程詳解
線程池中,常見有涉及到的:
ExecutorService executorService = Executors.newSingleThreadExecutor();ExecutorService executorService1 = Executors.newCachedThreadPool();ExecutorService executorService2 = Executors.newFixedThreadPool(3);
關于Executors和ExecutorService從記憶上類似于Collections和List。
但是以上幾種其實不建議使用。最好可以通過自己手動配置ThreadPoolExecutor的形式。
我先創建一個demo:
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(2,5,1L,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(3),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy() );
涉及7個參數,按順序分別是
int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler
具體我首先需要結合參數解釋下線程池的執行原理:
畫了張圖:
如果我用銀行辦理業務示例說明如下:
1、首先銀行里面有兩個柜臺,這就是核心線程數(7大參數之一)。
2、然后隨著客戶的增加,可能這個兩個柜臺滿了,然后就要請用戶到等候區里面進行等待。這個等候區就是相當于阻塞隊列(七大參數之一)。
3、然后緊接著客戶越來越多,連阻塞隊列都撐不住了,這個時候,就要請求,上面的領導進行多增加柜臺的操作,這個時候,可能加了三個柜臺,現在就有5個柜臺了。這個時候最大的線程數(七大參數之一)就是5了。
4、但是這個時候可能客戶又越來越多,這個時候新加的柜臺也受不了,就要開始有拒絕策略了(七大參數之一)
5、然后過了一段時間,慢慢的,客戶越來越少了,這個時候,發現漸漸的,柜臺空余出來了。KeepAliveTime(七大參數之一,加上單位,合計兩個參數)指當線程數大于核心線程數時,此為終止前多余的空閑線程等待新任務的最長時間。
6、還有一個參數是工廠,這個我們不做深入研究,直接用默認的工廠即可。
懂得原理以后,我們可以查看下,為什么最好不要直接用,比如:
Executors.newFixedThreadPool(3);
這個的主要原因就是這里面默認隊列的最大值是Integer的最大值。
所以我們生產中需要自己配置線程池。因為默認隊列的長度太長了,有可能會導致oom。就是內存炸掉了。
這個在阿里的編程思想里面也有說明這一點:
這邊我們探討下,拒絕策略。4種策略。就是所有柜臺和等候區全部滿了。會如何處理。
用非常easy的代碼來過下,這塊的內容:
1、AbortPolicy
import java.util.concurrent.*;public class VolatileTest { public static void main(String[] args) throws Exception { ExecutorService executorService = new ThreadPoolExecutor(2,5,1L,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(3),Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy() ); try { for (int i = 0; i < 9; i++) {executorService.execute(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName()+'t'+'辦理業務'); }}); } } catch (Exception e) { e.printStackTrace(); } finally { } }}
可以看到如果超出的話直接掛了,阻止正常運行。
2、CallerRunsPolicy
輸出
發現有一個退回main線程,被main線程處理。即會把任務退回至調用者。
3、DiscardOldestPolicy
這個將會等待時間最久的任務丟掉。
4、DiscardPolicy
多出來的任務會全部丟掉。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。
相關文章:
