java 线程池ThreadPoolExecutor

ExecutorService executor =new ThreadPoolExecutor(1, 1, 0, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024));

5个参数的意义：核心线程数，最大线程数，线程存活时间，时间单位，阻塞队列

参数说明 构造方法

线程池的流程

核心数->队列->最大线程数->拒绝策略

核心数没达到最大，每来一个任务创建一个核心线程，直到最大值。可以使用prestartAllCoreThreads()方法提前创建好核心线程

核心数达到最大值，将任务放到阻塞队列里面

阻塞队列满了，创建线程处理任务

达到了最大线程数，使用拒绝策略

该顺序可能会使得后来的线程优先执行

阻塞队列选择

ArrayBlockingQueue:数组实现的阻塞队列，FIFO

LinkedBlockingQueue：链表实现的阻塞队列，FIFO，数组会有数据迁移，所以链表的吞吐量大于数组

SynchronousQueue：不存储元素的阻塞队列，每个插入操作必须等到另一个线程调用 移除操作，否则插入操作一直处于阻塞状态

PriorityBlockingQueue：优先级无限阻塞队列

阻塞队列通常使用LinkedBlockingQueue，需要设置最大值，默认的最大值是Integer的最大值，可能会引起oom，需要自己设定一个合适的值

拒绝策略选择

AbortPolicy：直接抛出异常RejectedExecutionException。默认策略

CallerRunsPolicy：调用者线程执行任务

DiscardOldestPolicy：丢弃队列里面最老的任务

DiscardPolicy：不处理，直接丢掉

可以自定义拒绝策略，如日志记录等

执行线程池

ThreadPoolExecutor的任务执行方法实现在父类AbstractExecutorService里面，AbstractExecutorService实现了ExecutorService。(肯定有模版方法模式)。常用

execute()：提交不需要返回值的任务

submit()：用于提交需要返回值的任务，返回futrue进行判断或者取值

invokeAll()：执行给定的多个任务，返回futures

关闭线程池

shutdown：线程状态设置为SHUTDOWN，中断未执行的线程

shutdownNow：线程状态设置为STOP，尝试停止所有线程，包括执行的和未执行的

线程池设置

cpu密集型任务线程数和cpu数一致，io密集型尽可能多如cpu数*2