线程池的优点:
- 重用线程池中的线程,避免因为线程的创建和销毁带来的性能开销
- 能有效的控制线程的最大并发数,避免大量的线程之间相互抢占资源而导致阻塞
- 可以对线程进行管理,提供定时、定期、单线程、并发数控制等功能。比如通过ScheduledThreadPool线程池来执行X秒后,每隔X秒执行一次的任务。
Android常见的四种线程池:
Tags:FixedThreadPool CachedThreadPool ScheduledThreadPool SingleThreadExecutor
说之前,我们要首先了解ThreadPoolExecutor
,因为我们常见的这四种线程池,都是通过配置ThreadPoolExecutor
来实现自己的功能特性。
ThreadPoolExecutor的构造函数
public ThreadPoolExecutor(
//线程的核心线程数,默认情况下,核心线程会一直存活
//如果将allowCoreThreadTimeOut设置为true,闲置的核心线程就会有超时策略
//时间间隔由keepAliveTime指定,等待时间超过指定的时长,核心线程就会终止
int corePoolSize,
//线程池能容纳的最大线程数,当活动线程数达到最大线程数,后续的新任务就会被阻塞
int maximumPoolSize,
//非核心线程闲置的超时时长,超过则回收
long keepAliveTime,
//指定keepAliveTime的单位,比如TimeUnit.SECONDS
TimeUnit unit,
//线程池的任务队列,通过线程池的execute提交的Runnable对象会存储在这里
//例如Okhttp的线程池的工作队列采用了没有容量的SynchronousQueue
BlockingQueue<Runnable> workQueue,
//线程工厂,为线程池提供创建新线程的能力,通过newThread(Runnable rb)
ThreadFactory threadFactory,
//当线程池无法执行新任务,可能是由于任务队列已满或者无法成功执行任务
//就会抛出一个异常(RejectedExecutionException)
RejectedExecutionHandler handler)
这是OkHttp的线程池创建:
ExecutorService executorService =
new ThreadPoolExecutor(
//没有常存的核心线程
0,
//最多线程数为Integer.MAX_VALUE
Integer.MAX_VALUE,
//线程空闲时存活时间为60秒
60,
//指定为秒
TimeUnit.SECONDS,
//没有容量的SynchronousQueue,不保存任务,
//所以只要把任务添加进去就会执行
new SynchronousQueue<Runnable>(),
new ThreadFactory() {});
FixedThreadPool
FixedThreadPool是一种线程数量固定的线程池,只有核心线程并且这些核心线程没有超时机制,任务队列也没有大小限制。通常我们通过Executors的newFixedThreadPool创建:
ExecutorService executorService=Executors.newFixedThreadPool(10);
executorService.execute(runnable);
CachedThreadPool
CachedThreadPool是一种线程数量不定的线程池,只有非核心线程,并且最大线程数为Integer.MAX_VALUE,它采用了没有容量的SynchronousQueue,所以只要把任务添加进去就会执行。通常我们通过Executors的newCachedThreadPool创建:
ExecutorService executorService=Executors.newCachedThreadPool();
executorService.execute(runnable);
ScheduledThreadPool
ScheduledThreadPool的核心线程数量是固定的,而非核心线程数是没有限制的,并且当非核心线程闲置时会被立即回收。主要用于执行定时任务和具有固定周期的重复任务,通常我们通过Executors的newScheduledThreadPool创建:
ScheduledExecutorService executorService=Executors.newScheduledThreadPool(10);
//2000ms后执行runnable
executorService.schedule(runnable,2000, TimeUnit.MILLISECONDS);
//延迟10ms后,每隔1000ms执行一次runnable
executorService.scheduleAtFixedRate(runnable,10,1000,TimeUnit.MILLISECONDS);
SingleThreadExecutor
SingleThreadExecutor内部只有一个核心线程,它确保所有的任务都在同一个线程中执行,所以不需要这些任务之间处理线程同步问题,通常我们通过Executors的newSingleThreadExecutor创建:
ExecutorService executorService=Executors.newSingleThreadExecutor();
executorService.execute(runnable);