ThreadLocal和ThreadPoolExecutor

/**
 * ThreadLocalDemo
 */
public class ThreadLocalDemo {
    /**
     * withInitial底层用的是 new SuppliedThreadLocal<>(supplier);
     */
    ThreadLocal<Integer> num = ThreadLocal.withInitial(() -> 0);
    /**
     * 自增并输出num的值
     */
    public void inCreate() {
        Integer myNum = num.get();
        myNum++;
        System.out.println(Thread.currentThread().getName() + "----------->" + myNum);
        num.set(myNum);
    }
    public static void main(String[] args) {
        ThreadLocalDemo threadLocalDemo = new ThreadLocalDemo();
        for (int i = 1; i < 3; i++) {
            int finalI = i;
            new Thread(() -> {
                while (true) {
                    threadLocalDemo.inCreate();
                    try {
                        Thread.sleep(finalI * 1000L);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    }
}

/**
 * 线程池Demo
 * 说明线程池的运行机制：
 * 参数说明：
 * 核心线程数10个，一直存在不会被回收
 * 普通线程数最多10个，当普通线程空闲3秒就会被回收，（因为参数给定最多有20个线程，因此普通线程10个）
 * 工作队列可以容纳的任务数是20个
 *
 * 首先线程池中有10个核心线程一直存在，如果来了不超过10个任务，那么核心线程会自动执行这些任务。
 * 在核心线程都在执行任务时后续又来了任务，那么这些来的任务会加入到工作队列中，当核心线程空闲当时候就可以执行工作队列中的任务
 * 在工作队列满了的情况下后续又来了任务，这些来的任务会开启普通线程去执行，最多开10个普通线程
 * 在普通线程都用上的情况下又来了任务，那么会根据线程池配置的拒绝策略处理任务
 */
public class ThreadPoolDemo {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //工作队列
        LinkedBlockingQueue<Runnable> objects = new LinkedBlockingQueue<>(20);
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10,20,3L,TimeUnit.SECONDS,objects,new CustomPolicy());
        //prestartAllCoreThreads()初始化线程池的核心线程数，否则即使有任务到达，也不会被执行（因为没有核心线程）
        threadPoolExecutor.prestartAllCoreThreads();
        for (int i = 0; i < 50; i++) {
            //向线程池中提交若干任务
            threadPoolExecutor.submit(()->{
                try {
                    Thread.sleep(2000L);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(threadPoolExecutor.getActiveCount());
            });
        }
    }
}