最近一直在看《android开发艺术探索》，这本书是一本进阶书，书中讲解的好多知识从源码的角度对一个知识点进行多方面的剖析，很适合开发者进阶必读者。
好了，也不啰嗦了，在研究线程池部分时，由于是第一次接触，而且项目中刚好有需求要使用线程池，就结合查阅资料和阅读书籍对自己的理解进行总结。
1.为什么要使用线程池?
（1）减少在创建和销毁线程上所花的时间以及系统资源的开销。
（2）如不使用线程池，有可能造成系统创建大量线程而导致消耗完系统内存以及”过度切换”。
2.线程池适用场合?
（1）在项目中频繁的开启线程，需要多线程去处理不同的任务。
（2）需要监控线程的运行状态。
3. 线程池的遵循什么样的运行规则？
（1）如果线程池中的数量为达到核心线程的数量，则直接会启动一个核心线程来执行任务。
（2）如果线程池中的数量已经达到或超过核心线程的数量，则任务会被插入到任务队列中标等待执行。
（3）如果(2)中的任务无法插入到任务队列中，由于任务队列已满，这时候如果线程数量未达到线程池规定最大值，则会启动一个非核心线程来执行任务。
（4）如果(3)中线程数量已经达到线程池最大值，则会拒绝执行此任务，ThreadPoolExecutor会调用RejectedExecutionHandler的rejectedExecution方法通知调用者。
4.线程有哪些种类？
（1）newFixedThreadPool
该模式全部由核心线程去实现，并不会被回收，没有超时限制和任务队列的限制，会创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。实现代码如下:
public static ExecutorService newFixedThreadPool(int mThreads){
return new ThreadPoolExecutor(mThreads,mThreads,0L,TimeUtil.MILLISECONDS,new LinkedBlockingQueue());
}
（2）newCachedThreadPool
该模式下线程数量不定的线程池，只有非核心线程，最大值为Integer.MAX_VALUE，会创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。实现代码如下：
public static ExecutorService newCachedThreadPool(){
return new ThreadPoolExecutor(0,Integer.MAX_VALUE,60L,TimeUtil.SECONDS,new SynchronousQueue());
}
（3）newScheduledThreadPool
该模式下核心线程是固定的，非核心线程没有限制，非核心线程闲置时会被回收。会创建一个定长线程池，执行定时任务和固定周期的任务。实现代码如下:
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize){
return new SchduledThreadPoolExecutor(corePoolSize)
}
public SchduledThreadPoolExecutor(int corePoolSize){
super(corePoolSize,Integer.MAX_VALUE,0,NANOSECONDS,new DelayedWorkQueue());
}
（4）newSingleThreadExecutor
该模式下线程池内部只有一个线程，所有的任务都在一个线程中执行，会创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。实现代码如下：
public static ExecutorService newSingleThreadExecutor(){
return new FinalizableDelegatedExecutorService(newThreadPoolExecutor(1,1,
0L,TimeUtil.MILLISECONDS,new LinkedBlockingQueue()));
}
5.四种模式线程池如何使用?
使用案例程序如下:
Runnable runnable = new Runnable(){
public void run(){
SystemClock.sleep(2000);
}
}
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(4);
fixedThreadPool.execute(runnable);
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
cachedThreadPool.execute(runnable);
ScheduledExecutorService scheduledThereadPool = Executors.newScheduledThreadPool(4);
scheduledThereadPool.schedule()runnable,2000,TimeUtil.MAX_VALUE);//2000ms后执行。
//延迟10ms后，每隔1000ms执行一次
scheduledThereadPool.scheduleAtFixedRate(runnable,10,1000,TimeUtil.MILLISECONDS);
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
singleThreadExecutor.execute(runnable);
网友评论