JAVA線程池中隊列與池大小的關系 · java學習摘記

[JAVA線程池中隊列與池大小的關系](http://www.mamicode.com/info-detail-649256.html) JAVA線程池中隊列與池大小的關系 ? ? JAVA線程中對于線程池（ThreadPoolExecutor)中隊列，池大小，核心線程的關系寫出自己的理解： ????1：核心線程：簡單來講就是線程池中能否允許同時并發運行的線程的數量 ? ? 2：線程池大小：線程池中最多能夠容納的線程的數量。 ? ? 3：隊列：對提交過來的任務的處理模式。 ? ? 對于線程池與隊列的交互有個原則： ? ? 如果隊列發過來的任務，發現線程池中正在運行的線程的數量小于核心線程，則立即創建新的線程，無需進入隊列等待。如果正在運行的線程等于或者大于核心線程，則必須參考提交的任務能否加入隊列中去。 ????1：提交的任務能否加入隊列中 ????????1）如果提交的任務能加入隊列，考慮下隊列的值是否有設定，如果沒有設定，那么也就是不能創建新的線程，只能在隊列中等待，因為理論上隊列里面可以容納無窮大的任務等待。換句話說，此時的線程池中的核心線程數就是池中能否允許的最大線程數。那么池的最大線程數就沒有任何意義了。 ? ? ????2）如果提交的任務能加入隊列，隊列的值是有限定的，那么首先任務進入隊列中去等待，一旦隊列中滿了，則新增加的任務就進入線程池中創建新的線程。一旦線程池中的最大線程數超過了，那么就會拒絕后面的任務。 ? ? 2：如果提交的任務不能加入隊列 ? ? ? ? 1:）提交的任務不能加入隊列，此時就會創建新的線程加入線程池中，一旦超過線程池中最大的數量，則任務被拒絕。 ? ? 4：隊列的三種策略： 1. 1. 1. `[SynchronousQueue](http://www.mamicode.com/info-detail-649256.html "java.util.concurrent 中的類")? 直接提交，也就是上面講到的所有任務不進入隊列去等待。此時小于核心線程就增加，多于或等于核心線程數時，還是增加線程，最大為線程池中的最大允許。超出就拒絕。` 2. `[LinkedBlockingQueue](http://www.mamicode.com/info-detail-649256.html "java.util.concurrent 中的類")? 無界隊列此時超過核心線程后的任務全部加入隊列等待，系統最多只能運行核心線程數量的線程。這種方法相當于控制了并發的線程數量。` 3. `[ArrayBlockingQueue](http://www.mamicode.com/info-detail-649256.html "java.util.concurrent 中的類")? ?有界隊列 ?此時超過核心線程后的任務先加入隊列等待，超出隊列范圍后的任務就生成線程，但創建的線程最多不超過線程池的最大允許值。` ? ? ?5：如下源代碼： ????固定數量的線程池 ????public static ExecutorService newFixedThreadPool(int nThreads) { ? ? ? ? return new ThreadPoolExecutor(nThreads, nThreads, ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? 0L, TimeUnit.MILLISECONDS, ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? new LinkedBlockingQueue()); ? ? } ????可以看出，這個線程池的核心線程與最大線程為一個值，不等待，超出核心線程一定時間后的線程就被回收掉了。最多同時運行nThreads數量的線程。 ????單線程池（其實個人認為可以理解為就是核心線程為1的固定線程池） ?????public static ExecutorService newSingleThreadExecutor() { ? ? ? ? return new FinalizableDelegatedExecutorService ? ? ? ? ? ? (new ThreadPoolExecutor(1, 1, ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? 0L, TimeUnit.MILLISECONDS, ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? new LinkedBlockingQueue())); ? ? } ? ? 動態線程池（無界線程池） ? ????public static ExecutorService newCachedThreadPool() { ? ? ? ? return new ThreadPoolExecutor(0, Integer.MAX_VALUE, ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? 60L, TimeUnit.SECONDS, ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? new SynchronousQueue()); ? ? } ????可以看出，核心線程池為0，線程池的最大是無限，等待時間為60秒，隊列為直接提交。 ? ? 也就是說每次一個任務都直接生成一個線程，線程的無上限，但是一旦線程池中出現了空閑超過60秒的線程則被回收掉。 ? ? 總的說來，在使用中我們一般使用Executors類的靜態方法來創建線程池，除非我們對于線程池非常理解才能自己去靈活的規劃線程池類（可以用來繼承ThreadPoolExecutor）本文出自 “[JAVA學習記錄](http://www.mamicode.com/%E2%80%98http://20150523.blog.51cto.com%E2%80%98)” 博客，請務必保留此出處[http://20150523.blog.51cto.com/10261028/1654425](http://www.mamicode.com/%E2%80%98http://20150523.blog.51cto.com/10261028/1654425%E2%80%98)