今天查看了java的Executor框架源碼,在此記錄一下,以便查閱。
(一),Executor的線程池通過ThreadPoolExecutor實現,Executors是他的工廠類,這里只說三種常用的類, ?1,Executors.newSingleThreadExecutor():線程池中只有一個線程,當線程執行結束,或因為其他原因進入DEAD狀態,則會再次創建一個線程供使用; ?2,Executors.newFixedThreadPool(nThreads):固定數量的線程池,nThreads為線程池創建時指定的線程數量,當池中線程數量不足這個數時,如果有任務,則會新建一個線程,當線程執行結束,或因為其他原因進入DEAD狀態,則會再次創建一個線程供使用; ?3,Executors.newCachedThreadPool():比較智能的線程池,理論上說,沒有線程池數限制,如果jvm或計算機運行,可以一直創建,當然這是不存在的,一般jvm都會有線程上限。當有新任務的時候,自動創建線程來執行,當線程執行完畢后,或因其他原因停止后,如果沒有allowTimeOut限制,則會自動回收(一般是60s)。
(二)ThreadPoolExecutor是通過內部類Worker類來添加線程的,Worker類是一個Runnable對象,類中自身包含有一個Thread對象,當你在運行worker的run方法時,其實他啟動的就是他本身里的Thread;
(三)說了這么多,那么多線程的原理是什么? ?要知道這個,首先要明白,線程有5個狀態:new,runable,running,block,dead;當新建一個線程的時候,就是new狀態,當線程結束了,就是dead狀態。好了,也就是說,線程活著的時候就是在:runable, running, block狀態之間;
多線程的實現,也就是多線程的復用過程,也就是說要維持線程在這三個狀態之間轉換,如何做到呢?
剛剛說到,ThreadPoolExecutor是通過worker來添加線程的,那么在worker里的runWorker方法中,他會不斷的查詢workQueue(阻塞隊列)來取任務執行。那么workQueue的數據時如何添加的呢?
這里寫一下,當新任務來的時候,線程池的工作過程: 1,當前線程數 < corePoolSize:即當前運行的線程數,小于核心線程數量,則立即創建一個線程來執行任務;
2,當前線程數 >= corePoolSize AND workQueue未滿:此時,將任務添加到workQueue里,等待處理;
3,當前線程數 >= corePoolSize AND workQueue滿了 AND 當前線程數
|
新聞熱點
疑難解答