开门一张图
int corePoolSize :线程池中核心线程数。 < corePoolSize ,就会创建新线程 。 > corePoolSize 这个任务就会保存到BlockingQueue。 注意:线程池最开始是没有线程的,当有任务的时候才new线程,然后保持corePoolSize核心线程的大小数量。超过的话就根据keepAliveTime时间来关闭多余的线程。 如果调用prestartAllCoreThreads()方法就会一次性的启动corePoolSize 个数的线程
int maximumPoolSize, 允许的最大线程数,BlockingQueue也满了,< maximumPoolSize时候就会再次创建新的线程
long keepAliveTime, 线程空闲下来后,存活的时间,这个参数只在> corePoolSize才有用 TimeUnit unit, 存活时间的单位值
BlockingQueue<Runnable> workQueue, 保存任务的阻塞队列
ThreadFactory threadFactory, 创建线程的工厂,给新建的线程赋予名字
RejectedExecutionHandler handler :饱和策略
实现自己的饱和策略,实现RejectedExecutionHandler接口即可
execute(Runnable command) 不需要返回
Future<T> submit(Callable<T> task) 需要返回
shutdown(),shutdownNow();
shutdownNow():设置线程池的状态,还会尝试停止正在运行或者暂停任务的线程
shutdown()设置线程池的状态,只会中断所有没有执行任务的线程
机器的Cpu核心=Runtime.getRuntime().availableProcessors(); 线程数适当大一点,机器的Cpu核心数*2,
队列的选择上,应该使用有界,无界队列可能会导致内存溢出,OOM
原文:https://www.cnblogs.com/coder-lzh/p/10753815.html