线程池 - 重点（Juc-06）

简单介绍

线程池：三大方法、七大参数、四种拒绝策略

程序的运行，本质：占用系统资源！优化资源的使用！=> 池化技术

线程池、连接池、内存池、对象池

池化技术：事先准备好一些资源，有人要用，就来我这里拿，用完之后还给我，下个人再用

线程池的好处

1. 降低资源的消耗
2. 提高响应的速度
3. 方便管理

一句话总结：线程可以复用，控制最大并发数，管理线程

三大方法

阿里开发手册中这样讲

七大参数
源码分析
 public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }

public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

 public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

本质：ThreadPoolExecutor(),因为这三个方法都调用的这个方法
public ThreadPoolExecutor(int corePoolSize, //核心线程池大小
                              int maximumPoolSize,//最大核心线程池大小
                              long keepAliveTime,//超时了没有人调用就会释放
                              TimeUnit unit,//超时单位
                              BlockingQueue<Runnable> workQueue,//阻塞队列
                              ThreadFactory threadFactory,//线程工厂，创建线程用，一般不用懂
                              RejectedExecutionHandler handler//拒绝策略) {
        if (corePoolSize < 0 ||
            maximumPoolSize <= 0 ||
            maximumPoolSize < corePoolSize ||
            keepAliveTime < 0)
            throw new IllegalArgumentException();
        if (workQueue == null || threadFactory == null || handler == null)
            throw new NullPointerException();
        this.acc = System.getSecurityManager() == null ?
                null :
                AccessController.getContext();
        this.corePoolSize = corePoolSize;
        this.maximumPoolSize = maximumPoolSize;
        this.workQueue = workQueue;
        this.keepAliveTime = unit.toNanos(keepAliveTime);
        this.threadFactory = threadFactory;
        this.handler = handler;
    }

四种拒绝策略（自定义）

new ThreadPoolExecutor.AbortPolicy() 队列满了，还有人进来，不处理这个人的，抛出异常
new ThreadPoolExecutor.CallerRunsPolicy() 队列满了了的话哪里来的，去哪里，也就是让main线程去执行这个
new ThreadPoolExecutor.DiscardOldestPolicy() 队列满了就不处理，但是不会抛出异常 
new ThreadPoolExecutor.DiscardOldestPolicy() 队列满了，尝试和最早的竞争，但是不会抛出异常

代码
最大线程池到底应该如何定义
1.cpu 密集型，几核就是几，可以保持 cpu 效率最高

2.IO 密集型 判断程序中十分消耗 IO 的线程

如果程序 ：15 个大型任务，io 十分占用资源 ，那就设置为两倍

获取 cpu 的最大核心数
Runtime.getRuntime().availableProcessors()