Java 線程池之FixedThreadPool（Java代碼實戰-003）

 

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; /** * FixThreadPoolExecutorTest 定義一個可重用的固線程數的線程池 */
public class FixThreadPoolExecutorTest { public static void main(String[] args) { /* * 把處理請求任務的線程數設置為固定的10， corePoolSize = maxPoolSize = 10 * keepAliveTime設置為0L，表示空閑的線程會立刻終止 * workQueue則是使用LinkedBlockingQueue，但是沒有設置范圍，那么則是最大值（Integer.MAX_VALUE） * 這基本就相當於一個無界隊列了。 使用該“無界隊列”則會帶來哪些影響呢？當線程池中的線程數量等於corePoolSize * 時，如果繼續提交任務，該任務會被添加到阻塞隊列workQueue中，當阻塞隊列也滿了之后，則線程池會新建線程執行任務直到maximumPoolSize。  * 由於FixedThreadPool使用的是“無界隊列”LinkedBlockingQueue，那么maximumPoolSize參數無效， * 同時指定的拒絕策略AbortPolicy也將無效。而且該線程池也不會拒絕提交的任務，如果客戶端提交任務的速度快於任務的執行， * 那么keepAliveTime也是一個無效參數。 */ ExecutorService pool = Executors.newFixedThreadPool(10); // 始終只有10個線程來處理請求任務，來不及處理的任務會放置於阻塞隊列中
        for (int i = 0; i < 50; i++) { pool.submit(new Runnable() { @Override public void run() { System.out.println("hello world! Execute ThreadName=" + Thread.currentThread().getName()); } }); } } }