自定義線程池以及拒絕執行策略

package com.duchong.demo.demox.hutool.threadpool;

import com.google.common.util.concurrent.ThreadFactoryBuilder;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * 自定義線程池
 * @author DUCHONG
 * @since 2019-09-04 9:54
 **/
public class DiyThreadPool {

    private static int maxNum=30;

    public static void main(String[] args)throws Exception {
        //被拒絕執行的任務Runnable集合
        List<Runnable> rejectTask=new ArrayList<>();
        //設置預先創建線程的名稱格式
        ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("DiyThreadPool-%s").build();
        ThreadPoolExecutor poolExecutor=new ThreadPoolExecutor(2,5,10, TimeUnit.SECONDS, new LinkedBlockingQueue <Runnable> (10) ,threadFactory,
                (r,executor)->{
                //把拒絕的任務記錄日志,然后空閑時間解析再重新執行
                System.out.println("當前被拒絕任務為：" + r.toString());
                System.out.println("當前線程池大小為："+executor.getPoolSize());

                rejectTask.add(r);
            }
        );

        for (int i=1;i<=maxNum;i++){
            poolExecutor.execute(new Task("task---"+i));
        }

        poolExecutor.shutdown();

        System.out.println("需要繼續執行的任務列表：");
        rejectTask.forEach(System.out::println);
    }


    /**
     * 內部task線程類
     */
    static class Task extends Thread{

        String taskName;
        Task(String taskName){
            super(taskName);
            this.taskName=taskName;
        }

        @Override
        public void run() {

            System.out.println(Thread.currentThread().getName()+"----執行任務---"+taskName);
        }
    }
}