线程池优点
- 限流
控制线程总数,根据硬件人为控制使性能达到最优 - 复用
减少线程的频繁创建和销毁复用线程 - 效率
因为线程可复用任务相应更快
java中的线程池
Executors.newFixedThreadPool(nThreads);//固定线程数线程池
Executors.newCachedThreadPool();//有伸缩性线程池,线程60shou后回收
Executors.newSingleThreadExecutor();//只有一个核心线程的线程池
Executors.newSingleThreadScheduledExecutor();//定时任务线程池
Executors.newWorkStealingPool();//fork/join线程池
- Executors核心构造方法
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.corePoolSize = corePoolSize;
this.maximumPoolSize = maximumPoolSize;
this.workQueue = workQueue;
this.keepAliveTime = unit.toNanos(keepAliveTime);
this.threadFactory = threadFactory;
this.handler = handler;
}
- newFixedThreadPool
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, //核心线程数=传入线程数
nThreads,//最大线程数=传入线程数
0L,//超时间=0
TimeUnit.MILLISECONDS,//超时时间单位=秒
new LinkedBlockingQueue<Runnable>()//双向链表阻塞队列
);
}
- newCachedThreadPool
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(
0, //核心线程数=0
Integer.MAX_VALUE,//最大线程数=Integer最大值(可当做无限大)
60L, //超时时间=60
TimeUnit.SECONDS,//超时时间单位=秒
new SynchronousQueue<Runnable>()//不存储元素的阻塞队列
);
}
- newSingleThreadExecutor
public static ExecutorService newSingleThreadExecutor() {
return new FinalizableDelegatedExecutorService
(new ThreadPoolExecutor(1, 核心线程数=1
1,//最大线程数=1
0L,//超时时间0
TimeUnit.MILLISECONDS,//超时时间单位:毫秒
new LinkedBlockingQueue<Runnable>()//双向链表阻塞队列
));
}
执行流程图
image.png
问题
- 1.不建议使用Executors创建线程池?为什么?
Executors创建的线程池内置的参数,使开发人员在不用了解线程池各个参数的含义的情况下进行使用.
在实际生产环境上运行是十分危险的 - 2.线程池大小的设置?
CPU 核数:
IO密集型:每个线程执行时间长,cpu利用率低;可以多设置一些;CPU核数2或者 (线程等待时间+线程CUP时间)/线程CPU时间cup核数
CUP密集型:cpu核数+1
-3.线程池预热:
ThreadPollExecutor.prestartAllCoreThreads() - 4
execute()与 submit()的区别
submit(Callable<T>)执行待返回值的任务,根据返回值可知任务的执行结果
submit()不会抛出异常,异常根据Callable返回
