为什么要引入线程池
-
降低资源消耗:通过重复利用已创建的线程降低创建和销毁造成的消耗。
-
提高响应速度:当任务到达时,任务可以不需要等到线程创建就能立即执行。
-
提高线程的可管理性:线程是稀缺资源,如果无限制的创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以进行统一的分配,调优和监控。
默认线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 100, 10, TimeUnit.SECONDS, new PriorityBlockingQueue<Runnable>());
for(int index=0; index=100; index++){
executor.execute(new Runnable());
}
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
参数 |
说明 |
corePoolSize |
线程池中核心线程数量 |
maximumPoolSize |
最大能创建的线程数量 |
keepAliveTime |
非核心线程最大存活时间 |
unit |
keepAliveTime的时间单位 |
workQueue |
等待队列。当任务提交时,如果线程池中的线程数量大于等于corePoolSize的时候,把该任务放入等待队列
|
threadFactory |
线程创建工厂。默认使用Executors.defaultThreadFactory()来创建线程,线程具有相同的NORM_PRIORITY优先级并且是非守护线程 |
handler |
线程池的饱和拒绝策略。如果阻塞队列满了并且没有空闲的线程,这时如果继续提交任务,就需要采取一种策略处理该任务。 |
Executors提供的线程池
//单一线程数,同时只有一个线程存活,但线程等待队列无界
Executors.newSingleThreadExecutor();
//线程可复用线程池,核心线程数为0,最大可创建的线程数为Interger.max,线程复用存活时间是60s.
Executors.newCachedThreadPool();
//固定线程数量的线程池
Executors.newFixedThreadPool(int corePoolSize);
//可执行定时任务,延迟任务的线程池
Executors.newScheduledThreadPool(int corePoolSize);
关键函数
void execute(Runnable run)//提交任务,交由线程池调度
void shutdown()//关闭线程池,等待任务执行完成
void shutdownNow()//关闭线程池,不等待任务执行完成
int getTaskCount()//返回线程池找中所有任务的数量
int getCompletedTaskCount()//返回线程池中已执行完成的任务数量
int getPoolSize()//返回线程池中已创建线程数量
int getActiveCount()//返回当前正在运行的线程数量
状态流转
线程池状态
execute提交任务
execute
网友评论