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