2. 線程池——自定義線程工廠、ThreadPoolExecutor方法的重寫

package concurrent;

import java.util.concurrent.*;

public class C02_ExThreadpool {
	
    public static class MyTask implements Runnable{
        private String name;
        public MyTask(String name){ this.name = name; }
        public String getName() { return name; }
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getId() + ":" + name);
            try{ Thread.sleep(1000);}
            catch (InterruptedException e) { e.printStackTrace(); }
        }
    }

    /**
     * .經過自定義的線程工廠能夠自定義線程的狀態等信息
     */
    public static class MyThreadFactory implements ThreadFactory{

        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r);
//            t.setDaemon(true);  //設置爲守護線程，主線程退出後自動銷燬
            System.out.println("create " + t);
            return t;
        }
    }


    public static void main(String[] args) throws InterruptedException{
        /*
        *.建立線程池，並重寫線程池的beforeExecute、afterExecute、terminated。
        *.這三個方法默認時空的，但咱們能夠重寫去作一些事情
         */
        ExecutorService es = new ThreadPoolExecutor(5, 5, 0L, TimeUnit.MICROSECONDS,
                new LinkedBlockingDeque<>(), new MyThreadFactory()) {
            @Override
            protected void beforeExecute(Thread t, Runnable r) {
                System.out.println("準備執行：" + ((MyTask)r).getName());
            }

            @Override
            protected void afterExecute(Runnable r, Throwable t) {
                System.out.println("執行完成：" + ((MyTask)r).getName());
            }

            @Override
            protected void terminated() {
                System.out.println("線程池退出");
            }
        };
        //添加任務
        for(int i=0 ; i<3 ; i++){
            es.execute(new MyTask("Task-" + i));
            Thread.sleep(10);
        }
        es.shutdown();  //發送一個信號給線程池，線程池在完成當前全部任務後關閉
    }
}

console

create Thread[Thread-0,5,main]
準備執行：Task-0
11:Task-0
create Thread[Thread-1,5,main]
準備執行：Task-1
12:Task-1
create Thread[Thread-2,5,main]
準備執行：Task-2
13:Task-2
執行完成：Task-0
執行完成：Task-1
執行完成：Task-2
線程池退出