1. 線程池——ThreadPoolExecutor

package concurrent;

import java.util.concurrent.*;

public class C01_Threadpool {

    /**
     * .使用自定義線程池與拒絕策略.詳見《實戰JAVA高併發程序設計》P103
     * .注意！！！！不建議直接使用ThreadPoolExecutor，而是要對它進行增強。緣由是
     * ThreadPoolExecutor不可以獲得異常消息，一旦發生錯誤將無跡可尋。
     * .具體看C03_TraceThreadPoolExecutor，或《實戰JAVA高併發程序設計》P113  3.2.8
     */
    public static void main(String[] args) throws InterruptedException{
        //定義提交的任務
        Runnable task = () -> {
            System.out.println(System.currentTimeMillis() + ":Thread ID:" + Thread.currentThread().getId());
            try{
              Thread.sleep(1000);
            }catch (InterruptedException e){
                e.printStackTrace();
            }
        };
        //定義拒絕策略
        RejectedExecutionHandler reject = (r, executor) -> System.out.println(r.toString() + " is discard...");
        //建立線程池
        ExecutorService es = new ThreadPoolExecutor(
                3,          //核心線程數
                5,      //最大線程數
                60L,       //空閒線程生存時間
                TimeUnit.SECONDS,       //空閒線程生存時間的單位
                new LinkedBlockingDeque<Runnable>(5),//沒法分配線程時的預備隊列(若隊列也滿又出現新的任務，那麼使用拒絕策略)
                Executors.defaultThreadFactory(),   //使用默認的線程工廠建立線程
                reject  //使用自定義的拒絕策略，在這裏咱們能夠將信息反饋到日誌中
        );
        //提交任務
        for(int i=0 ; i<15 ; i++){
            es.submit(task);
            Thread.sleep(10);
        }
        es.shutdown();  //發送一個信號給線程池，線程池在完成當前全部任務後關閉

        System.out.println("當前可用處理器個數：" + Runtime.getRuntime().availableProcessors());
    }
}

console

1550995388971:Thread ID:11
1550995388981:Thread ID:12
1550995388991:Thread ID:13
1550995389052:Thread ID:14
1550995389061:Thread ID:15
java.util.concurrent.FutureTask@4eec7777 is discard...
java.util.concurrent.FutureTask@3b07d329 is discard...
java.util.concurrent.FutureTask@41629346 is discard...
java.util.concurrent.FutureTask@404b9385 is discard...
java.util.concurrent.FutureTask@6d311334 is discard...
當前可用處理器個數：8
1550995389972:Thread ID:11
1550995389981:Thread ID:12
1550995389991:Thread ID:13
1550995390052:Thread ID:14
1550995390062:Thread ID:15