一:什么是线程池?

  java 线程池是将大量的线程集中管理的类,包括对线程的创建,资源的管理,线程生命周期的管理。当系统中存在大量的异步任务的时候就考虑使用java线程池管理所有的线程。减少系统资源的开销。

二:线程池工厂类有多少种?

  java1.8 的官方文档提供了三种线程池工厂类,每种线程池工厂类型对应不同线程管理方式(策略)。

  newCachedThreadPool(自动废弃回收):

  当有可用的空闲线程,优先使用空闲线程,当没有可用的空闲线程的时候就创建新的线程。空闲线程超过60s没有被使用,将会关闭并从线程缓冲区中删除。这种设计的好处就是当并发高峰期过了之后,大量的空闲线程就会被回收,节省系统资源。

  newFixedhreadPool(固定线程池大小):

  首先创建一个固定线程大小的线程池,将所有的线程激活,创建一个无界任务队列存放所有的任务,当线程池中有可用的空闲线程,队列的任务就会被消费,当线程池中没有空闲线程,任务队列中的任务就等待,直到有线程被空出。当某个线程应为运行期间被异常关闭,其他的线程将会接替其运行后来的任务。这种线程池的好处就是不会再高峰的时候一直创建新的线程。线程空闲的时候也不会被销毁。除非程序员手动明确的调用关闭线程池的方法。                 

  newSingleThreadExecutor(单工作线程): 任何时候都只有一个线程被激活处理无界任务队列,当运行中的线程因为异常而关闭的时候,新的线程将被创建,这样的线程池将保证所有的任务顺序执行。

三:测试线程池demo

package test.thread.threadPool;

import org.junit.Test;

import java.util.concurrent.*;

/**
* 线程池
*/
public class ThreadPool { /**
* @version 经过测 试发现Junit的@Test注解不支持多线程,当单元测试的线程关闭之后,就会关闭所有的线程
* @see @Test 注解会调用System.exit(0); 方法退出程序异步线程无法执行
*/
public static void main(String[] args){
/*
* 创建一个线程的实例
* 核心线程大小5
* 最大线程大小10
* 线程没有处理任务的时候存活的时间
* 创建一个数组阻塞队列(队列的长度为5)
* */
ThreadPoolExecutor executor = new ThreadPoolExecutor(5,10,8000,
TimeUnit.MILLISECONDS, new LinkedBlockingDeque<Runnable>());
for(int i=0;i<15;i++){
MyTask myTask = new MyTask(executor);
//两种方法调用将任务加入到阻塞队列中submit(Runnable) 和 excute(Runnable) 方法
executor.submit(myTask); //线程执行完毕返回一个future对象
}
} }
class MyTask implements Runnable { private ThreadPoolExecutor executor; public MyTask(ThreadPoolExecutor ex){
this.executor=ex;
} @Override
public void run() {
synchronized (executor) { //加锁监视器的目的是应为多个线程修改数据,调用get方法可能获取数不对
System.out.println("线程-" + Thread.currentThread().getId() + ":正在执行task ");
try {
//线程休眠三秒更直观的查看效果
Thread.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程池中核心线程数目:" + executor.getPoolSize() + ",队列中等待执行的任务数目:" +
executor.getQueue().size() + ",已执行完成的任务数目:" + executor.getCompletedTaskCount());
}
}
}

源码解析:ThreadPoolExecutor 是线程池的核心类,他有四个构造函数,分别是为了选择不同的线程工厂策略,异常处理,任务管理。

 public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue) {
this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
Executors.defaultThreadFactory(), defaultHandler); //默认线程工厂和处理器
}
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit, BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory)
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler)
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)

  corePoolSzie:这个参数是线程池的核心参数,表示当前线程数小于corePoolSize的时候,线程池每接收一个新的任务将创建一个新的线程,即使有空闲的线程也不会复用。 

  maximumPooSize:最大线程池拥有的线程数,当线程池中的线程数大于corePoolSize的时候,先复用corePoolSize中的空闲线程,当没有空闲线程的时候就创建新的线程,但是线程的总数不会超过maximunPoolSize.

  keepAliveTime:非核心线程能存活的最大时间。当线程数超过corePoolSize的时候,当有空闲的线程时间超过keepAliveTime将会被回收。

  unit:时间的单位,用TimeUnits这个类的类属性。属性包含NANOSECONDS,MICROSECONDS,MILLISECONDS,SECONDS,MINUTES,HOUR,DAYS

  workQueue:线程池将要消费的任务,这个任务的类型必须是线程,要继承Runnable 的接口,就这是为什么要叫线程池,对于阻塞队列,一般会有ArrayBlockQque,LinkedBlockQueue,synchronousQueue 三种。

  defaultHandlerExecutor:默认的拒绝策略,当线程池关闭的时候,新的任务将被拒绝,并且展现不同的处理策略

  注意:excutor.shutDown(); 方法是将线程池关闭,已经在线程池中的任务将会继续执行,没有被接受的任务将不会在处理。

     当线程池的队列用的ArrayBlockQque 的时候,若线程池中的所有线程都被用完,并且还有任务进入队里将会抛出RejectedExecutionException

四:方法解析

  ThreadExcutor 类最高继承接口Executor,Executor 这个接口只生命了一个方法:execute(Runnable commond)

  类uml图

Executor 接口:execute(Runnable commond) 方法是调用线程的核心方法

ExecutorService 接口:提供了管理异步线程的方法。

    shutdown() :将当前正在执行的异步任务继续执行,不再接受新的任务进入线程池。

    shutdownNow():将当前正执行的线程关闭,不在接受新的任务进入线程池。

    submit():将任务提交到线程池中,并且会返回Future对象。底层调用的是Runnable 的run()方法或者是callable 的call()方法

AbstractExecutorService: 实现了submit 方法,提供线程返回值,但是这种线程的执行是直接的调用的run() 方法,导致最后线程池所有的线程都是顺序执行,并不是异步的

ThreadExecutor 提供了创建线程池的构造函数,以及拒绝策略,还有各种监控线程执行状态的方法。

  

  

  

java 线程池第一篇 之 ThreadPoolExcutor的更多相关文章

  1. 并发包的线程池第一篇--ThreadPoolExecutor执行逻辑

    学习这个很长时间了一直没有去做个总结,现在大致总结一下并发包的线程池. 首先,任何代码都是解决问题的,线程池解决什么问题? 如果我们不用线程池,每次需要跑一个线程的时候自己new一个,会导致几个问题: ...

  2. Java线程入门第一篇

    Java线程的状态有6种 1.  初始(NEW):新创建了一个线程对象,但还没有调用start()方法. 2.  运行(RUNNABLE):Java线程中将就绪(ready)和运行中(running) ...

  3. Java线程池详解,看这篇就够了!

    构造一个线程池为什么需要几个参数?如果避免线程池出现OOM?Runnable和Callable的区别是什么?本文将对这些问题一一解答,同时还将给出使用线程池的常见场景和代码片段. 基础知识 Execu ...

  4. Java线程池与java.util.concurrent

    Java(Android)线程池 介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行 ...

  5. java线程池的使用与详解

    java线程池的使用与详解 [转载]本文转载自两篇博文:  1.Java并发编程:线程池的使用:http://www.cnblogs.com/dolphin0520/p/3932921.html   ...

  6. 并发编程(十二)—— Java 线程池 实现原理与源码深度解析 之 submit 方法 (二)

    在上一篇<并发编程(十一)—— Java 线程池 实现原理与源码深度解析(一)>中提到了线程池ThreadPoolExecutor的原理以及它的execute方法.这篇文章是接着上一篇文章 ...

  7. 并发编程(十一)—— Java 线程池 实现原理与源码深度解析(一)

    史上最清晰的线程池源码分析 鼎鼎大名的线程池.不需要多说!!!!! 这篇博客深入分析 Java 中线程池的实现. 总览 下图是 java 线程池几个相关类的继承结构:    先简单说说这个继承结构,E ...

  8. Netty核心概念(7)之Java线程池

    1.前言 本章本来要讲解Netty的线程模型的,但是由于其是基于Java线程池设计而封装的,所以我们先详细学习一下Java中的线程池的设计.之前也说过Netty5被放弃的原因之一就是forkjoin结 ...

  9. 深入理解Java线程池:ScheduledThreadPoolExecutor

    介绍 自JDK1.5开始,JDK提供了ScheduledThreadPoolExecutor类来支持周期性任务的调度.在这之前的实现需要依靠Timer和TimerTask或者其它第三方工具来完成.但T ...

随机推荐

  1. shell 使用

    echo -e "1\t2\t3" #-e echo -e "\e[1;31m This is red text \e[0m" #color echo -e & ...

  2. Android渲染机制和丢帧分析

    http://blog.csdn.net/bd_zengxinxin/article/details/52525781 自己编写App的时候,有时会感觉界面卡顿,尤其是自定义View的时候,大多数是因 ...

  3. BZOJ1677: [Usaco2005 Jan]Sumsets 求和

    1677: [Usaco2005 Jan]Sumsets 求和 Time Limit: 5 Sec  Memory Limit: 64 MBSubmit: 570  Solved: 310[Submi ...

  4. MEF初体验之二:定义组合部件和契约

    组合部件 在MEF中,一个组合部件就是一个组合单元,组合部件"出口"其它组合部件需要的服务并且从其它部件"进口"需要的服务.在MEF编程模型中,为了声明组合部件 ...

  5. TCP粘包、拆包及解决

    TCP属于传输层的协议,传输层除了有TCP协议外还有UDP协议.那么UDP是否会发生粘包或拆包的现象呢?答案是不会.UDP是基于报文发送的,从UDP的帧结构可以看出,在UDP首部采用了16bit来指示 ...

  6. img2html实现将图片转换成网页

    简单介绍img2html的用法,安装就不用说了pip.这个包现只支持python2,支持python的话需改下源码这几个部分: 加注释的是修改的地方 #!/usr/bin/env python # e ...

  7. 20165207 2017-2018-2《Java程序设计》课程总结

    20165207 2017-2018-2<Java程序设计>课程总结 每周作业链接汇总 预备作业1:我期望的师生关系 预备作业2:学习基础与C语言调查反馈 预备作业3:Linux安装与命令 ...

  8. TreeMap源码剖析

    原文  http://blog.csdn.net/chdjj/article/details/38782221 主题 源码分析红黑树 注:以下源码基于jdk1.7.0_11 之前介绍了一系列Map集合 ...

  9. C语言学习笔记--条件编译

    C语言中的条件编译的行为类似于 C 语言中的 if…else…,是预编译指示命令,用于控制是否编译某段代码 . 1.条件编译的本质 (1)预编译器根据条件编译指令有选择的删除代码 (2)编译器不知道代 ...

  10. Mycat(1)

    https://www.jianshu.com/p/26513f428ecf https://blog.csdn.net/fly910905/article/details/87101059 http ...