java多线程-概念&创建启动&中断&守护线程&优先级&线程状态（多线程编程之一）
java多线程同步以及线程间通信详解&消费者生产者模式&死锁&Thread.join()（多线程编程之二）
java&android线程池-Executor框架之ThreadPoolExcutor&ScheduledThreadPoolExecutor浅析（多线程编程之三）
Java多线程：Callable、Future和FutureTask浅析（多线程编程之四）

无论是在java还是在android中其实使用到的线程池都基本是一样的，因此本篇我们将来认识一下线程池Executor框架（相关知识点结合了并发编程艺术书以及Android开发艺术探索而总结），下面是本篇的主要知识点：

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory) {this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,threadFactory, defaultHandler);}

ExecutorService fixedThreadPool=Executors.newFixedThreadPool(5);

我们来看看FixedThreadPool创建方法源码：

public static ExecutorService newFixedThreadPool(int nThreads) {return new ThreadPoolExecutor(nThreads, nThreads,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>());}

FixedThreadPool的corePoolSize和maximumPoolSize参数都被设置为nThreads。当线程池中的线程数量大于corePoolSize时，keepAliveTime为非核心空闲线程等待新任务的最长时间，超过这个时间后非核心线程将被终止，这里keepAliveTime设置为0L，就说明非核心线程会立即被终止。事实上这里也没有非核心线程创建，因为核心线程数和最大线程数都一样的。下面我们来看看FixedThreadPool的execute()方法的运行流程：

public class LiftOff implements Runnable{   protected int countDown = 10; //Default   private static int taskCount = 0;   private final int id = taskCount++;    public LiftOff() {}   public LiftOff(int countDown) {   this.countDown = countDown;   }   public String status() {   return "#" + id + "(" +   (countDown > 0 ? countDown : "LiftOff!") + ") ";   }   @Override   public void run() {   while(countDown-- > 0) {   System.out.print(status());   Thread.yield();   }   }
}

声明一个Runnable对象，使用FixedThreadPool执行任务如下：

public class FixedThreadPool {   public static void main(String[] args) {  //三个线程来执行五个任务   ExecutorService exec = Executors.newFixedThreadPool(3);      for(int i = 0; i < 5; i++) {   exec.execute(new LiftOff());   }  exec.shutdown();   }
}

ExecutorService cachedThreadPool=Executors.newCachedThreadPool(); 

public static ExecutorService newCachedThreadPool() {return new ThreadPoolExecutor(0, Integer.MAX_VALUE,60L, TimeUnit.SECONDS,new SynchronousQueue<Runnable>());}

从该静态方法，我们可以看到CachedThreadPool的corePoolSize被设置为0，而maximumPoolSize被设置Integer.MAX_VALUE，即maximumPoolSize是无界的，而keepAliveTime被设置为60L，单位为妙。也就是空闲线程等待时间最长为60秒，超过该时间将会被终止。而且在这里CachedThreadPool使用的是没有容量的SynchronousQueue作为线程池的工作队列，但其maximumPoolSize是无界的，也就是意味着如果主线程提交任务的速度高于maximumPoolSize中线程处理任务的速度时CachedThreadPool将会不断的创建新的线程，在极端情况下，CachedThreadPool会因为创建过多线程而耗尽CPU和内存资源。CachedThreadPool的execute()方法的运行流程：

CachedThreadPool使用的案例代码如下：

public class CachedThreadPool {   public static void main(String[] args) {   ExecutorService exec = Executors.newCachedThreadPool();   for(int i = 0; i < 10; i++) {   exec.execute(new LiftOff());   }   exec.shutdown();       }
}

ExecutorService singleThreadExecutor=Executors.newSingleThreadExecutor(); 

public static ExecutorService newSingleThreadExecutor() {return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>()));}

从静态方法可以看出SingleThreadExecutor的corePoolSize和maximumPoolSize被设置为1，其他参数则与FixedThreadPool相同。SingleThreadExecutor使用的工作队列也是无界队列LinkedBlockingQueue。由于SingleThreadExecutor采用无界队列的对线程池的影响与FixedThreadPool一样，这里就不过多描述了。同样的我们先来看看其运行流程：

public class SingleThreadExecutor {   public static void main(String[] args) {   ExecutorService exec = Executors.newSingleThreadExecutor();   for (int i = 0; i < 2; i++) {   exec.execute(new LiftOff());   }   }
}

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)

public static ScheduledExecutorService newSingleThreadScheduledExecutor()
public static ScheduledExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory)

创建实例对象代码如下：

ScheduledExecutorService scheduledThreadPoolExecutor=Executors.newScheduledThreadPool(5);

ScheduledExecutorService singleThreadScheduledExecutor=Executors.newSingleThreadScheduledExecutor();

public ScheduledFuture<?> schedule(Runnable command,long delay, TimeUnit unit);

package com.zejian.Executor;
import java.text.ParsePosition;
import java.text.SimpleDateFormat;
import java.util.Date;
/*** @author zejian* @time 2016年3月14日 下午9:10:41* @decrition 创建一个工作线程继承Runnable*/
public class WorkerThread implements Runnable{@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+" Start. Time = "+getNowDate());threadSleep();System.out.println(Thread.currentThread().getName()+" End. Time = "+getNowDate());}/*** 睡3秒*/public void threadSleep(){try {Thread.sleep(3000);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}/*** 获取现在时间* * @return 返回时间类型 yyyy-MM-dd HH:mm:ss*/public static String getNowDate() {Date currentTime = new Date();SimpleDateFormat formatter; formatter = new SimpleDateFormat ("yyyy-MM-dd HH:mm:ss"); String ctime = formatter.format(currentTime); return ctime;}
}

执行类如下：

package com.zejian.Executor;
import java.text.ParsePosition;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/*** @author zejian* @time 2016年3月14日 下午9:27:06* @decrition 执行类*/
public class ScheduledThreadPoolTest {public static void main(String[] args) {ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);try {//schedule to run after sometimeSystem.out.println("Current Time = "+getNowDate());for(int i=0; i<3; i++){Thread.sleep(1000);WorkerThread worker = new WorkerThread();//延迟10秒后执行scheduledThreadPool.schedule(worker, 10, TimeUnit.SECONDS);}Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}scheduledThreadPool.shutdown();while(!scheduledThreadPool.isTerminated()){//wait for all tasks to finish}System.out.println("Finished all threads");}/*** 获取现在时间* * @return 返回时间类型 yyyy-MM-dd HH:mm:ss*/public static String getNowDate() {Date currentTime = new Date();SimpleDateFormat formatter; formatter = new SimpleDateFormat ("yyyy-MM-dd HH:mm:ss"); String ctime = formatter.format(currentTime); return ctime;}
}

运行输入执行结果：

线程任务确实在10秒延迟后才开始执行。这就是schedule()方法的使用。下面我们再介绍2个可用于周期性执行任务的方法。

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit)

scheduleAtFixedRate方法的作用是预定在初始的延迟结束后，周期性地执行给定的任务，周期长度为period，其中initialDelay为初始延迟。

（按照固定的时间来执行，即：到点执行）

 public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit);

package com.zejian.Executor;
import java.util.Date;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/*** @author zejian* @time 2016年3月14日 下午10:05:07* @decrition 周期函数测试类*/
public class ScheduledTask {public ScheduledThreadPoolExecutor se = new ScheduledThreadPoolExecutor(5);public static void main(String[] args) {new ScheduledTask();}public void fixedPeriodSchedule() {// 设定可以循环执行的runnable,初始延迟为0，这里设置的任务的间隔为5秒for(int i=0;i<5;i++){se.scheduleAtFixedRate(new FixedSchedule(), 0, 5, TimeUnit.SECONDS);}}public ScheduledTask() {fixedPeriodSchedule();}class FixedSchedule implements Runnable {public void run() {System.out.println("当前线程："+Thread.currentThread().getName()+"  当前时间："+new Date(System.currentTimeMillis()));}}
}

当前线程：pool-1-thread-5  当前时间：Tue Aug 08 09:43:18 CST 2017
当前线程：pool-1-thread-4  当前时间：Tue Aug 08 09:43:18 CST 2017
当前线程：pool-1-thread-3  当前时间：Tue Aug 08 09:43:18 CST 2017
当前线程：pool-1-thread-1  当前时间：Tue Aug 08 09:43:18 CST 2017
当前线程：pool-1-thread-2  当前时间：Tue Aug 08 09:43:18 CST 2017
当前线程：pool-1-thread-1  当前时间：Tue Aug 08 09:43:23 CST 2017
当前线程：pool-1-thread-4  当前时间：Tue Aug 08 09:43:23 CST 2017
当前线程：pool-1-thread-3  当前时间：Tue Aug 08 09:43:23 CST 2017
当前线程：pool-1-thread-5  当前时间：Tue Aug 08 09:43:23 CST 2017
当前线程：pool-1-thread-2  当前时间：Tue Aug 08 09:43:23 CST 2017
当前线程：pool-1-thread-1  当前时间：Tue Aug 08 09:43:28 CST 2017
当前线程：pool-1-thread-4  当前时间：Tue Aug 08 09:43:28 CST 2017
当前线程：pool-1-thread-5  当前时间：Tue Aug 08 09:43:28 CST 2017
当前线程：pool-1-thread-3  当前时间：Tue Aug 08 09:43:28 CST 2017
当前线程：pool-1-thread-1  当前时间：Tue Aug 08 09:43:28 CST 2017

主要参考书籍：

java核心技术卷1

android开发艺术探索

java并发编程的艺术

---------------------
作者：zejian_
来源：CSDN
原文：https://blog.csdn.net/javazejian/article/details/50890554
版权声明：本文为作者原创文章，转载请附上博文链接！
内容解析By：CSDN,CNBLOG博客文章一键转载插件

[转]javaandroid线程池相关推荐

1. java 手编线程池_死磕 java线程系列之自己动手写一个线程池

   欢迎关注我的公众号"彤哥读源码",查看更多源码系列文章, 与彤哥一起畅游源码的海洋. (手机横屏看源码更方便) 问题 (1)自己动手写一个线程池需要考虑哪些因素? (2)自己动手写 ...

2. Python 多线程总结（2）— 线程锁、线程池、线程数量、互斥锁、死锁、线程同步

   主要介绍使用 threading 模块创建线程的 3 种方式,分别为: 创建 Thread 实例函数 创建 Thread 实例可调用的类对象 使用 Thread 派生子类的方式 多线程是提高效率的一种 ...

3. 详解 Tomcat 的连接数与线程池

   原文出处:编程迷思 前言 在使用tomcat时,经常会遇到连接数.线程数之类的配置问题,要真正理解这些概念,必须先了解Tomcat的连接器(Connector). 在前面的文章 详解Tomcat配置文 ...

4. Android线程池简单使用

   线程池使用的好处: 1)对多个线程进行统一地管理,避免资源竞争中出现的问题. 2)对线程进行复用,线程在执行完任务后不会立刻销毁,而会等待另外的任务,这样就不会频繁地创建.销毁线程和调用GC. 使用T ...

5. 四种Java线程池用法解析

   四种Java线程池用法解析 本文为大家分析四种Java线程池用法,供大家参考,具体内容如下 http://www.jb51.net/article/81843.htm 1.new Thread的弊端 ...

6. python基础-第九篇-9.3线程池

   简单版 import queue import threadingclass ThreadPool(object):def __init__(self, max_num=20):self.queue ...

7. mongodb线程池_常用高并发网络线程模型设计及MongoDB线程模型优化实践

   服务端通常需要支持高并发业务访问,如何设计优秀的服务端网络IO工作线程/进程模型对业务的高并发访问需求起着至关重要的核心作用. 本文总结了了不同场景下的多种网络IO线程/进程模型,并给出了各种模型的优 ...

8. 面试必问---Java线程池8大拒绝策略

   前言 谈到java的线程池最熟悉的莫过于ExecutorService接口了,jdk1.5新增的java.util.concurrent包下的这个api,大大的简化了多线程代码的开发.而不论你用Fix ...

9. 基于C++实现线程池加速

   经过长期探索,发现一个不需要手动设置线程休眠时间(e.g. std::this_thread::sleep_for(std::chrono::microseconds(1)))的代码: Github: ...

最新文章

1. WaitForSingleObject和WaitForMultipleObjects用法
2. UA MATH567 高维统计I 概率不等式9 亚高斯性的推广：Orlicz空间与Orlicz范数
3. docker 容器安装conposer_docker学习笔记（二）docker-composer
4. 家庭财务管理系统_我31岁，30天整理出这些财务笔记干货，从宝妈成功逆袭成为会计...
5. IIS 6.0 401 错误
6. 华数联手海信升级互联网电视平台
7. 【堆】这是要搞事情啊——取出
8. hihocoder1033交错和
9. 记录gns3出现各种erro报错以及具体修复过程
10. 省钱兄（微信小程序、h5版本）uniapp淘宝客小程序源码商城前端源码
11. oc实时渲染的图如何导出_如何高效学习C4D？看完这篇文章你就知道了！
12. 小游戏市场被微信点燃，社交平台蜂拥而至谁能分到蛋糕？
13. 计算机网络练习题-2
14. win7禁用显示方向旋转快捷键
15. scrapy数据存入mysql_Scrapy爬虫实例教程（二）---数据存入MySQL
16. 架构设计分布式数据结构与算法面试题（2020最新版）
17. 与CVTE的完美“邂逅”
18. ios微信浏览器App下载链接怎样跳转到苹果App Store
19. 如何采集人类高质量脑电波？| 脑电设备推荐
20. Windows 打开 Docker Desktop 出现错误：Docker failed to initialize

热门文章

1. Json.Net系列教程 3.Json.Net序列化和反序列化设置
2. struts.properties属性解释
3. 2010.7.27 OnDraw与OnPaint有什么区别
4. .NET 基金会项目介绍 - ReactiveUI
5. Dapr + .NET 实战（九）本地调试
6. 浅析 Dapr 里的云计算设计模式
7. 为什么应该用record来定义DTO（续）
8. 并行中的分区Partitioner
9. 联机分析的列式数据库 clickHouse
10. C# FileSystemWatcher文件监控实例