深入浅出JAVA线程池使用原理2

一、Executor框架介绍

Executor框架将Java多线程程序分解成若干个任务,将这些任务分配给若干个线程来处理,并得到任务的结果

1.1、Executor框架组成

任务:被执行任务需要实现的接口:Runnable接口或Callable接口

任务的执行:任务执行的核心接口Executor以及其子类ExecutorService接口

任务的结果:包括Future接口以及Future接口的实现类FutureTask类

Executor接口是Executor框架的基础,将任务的提交与执行分离开

ThreadPoolExecutor:线程池核心实现类,用来执行提交的任务

ScheduledThreadPoolExecutor:在给定的延迟时间后执行或定期执行任务,相当于ThreadPoolExecutor的定时器版本

Future接口和实现类FutureTask代表异步处理的结果

Runnable接口和Callable接口都是当做任务被ThreadPoolExecutor和ScheduledThreadPoolExecutor来执行

二、ThreadPoolExecutor详解

ThreadPoolExecutor通常可以使用工厂类Executors来创建,可以有以下三种类型:

SingleThreadExecutor:单线程线程池执行器,适用于需要保证顺序地执行各个任务且不会出现多线程同时活动的情况

FixedThreadPool:创建使用固定线程数量的线程池,可以限制当前线程数量,比较常用。

CachedThreadPool:大小无界的线程池,适用于需要执行大量短期异步任务的场景或者是服务器负载较小的情况

2.1、FixedThreadPool详解

源码如下:

1 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
2         return new ThreadPoolExecutor(nThreads, nThreads,
3                                       0L, TimeUnit.MILLISECONDS,
4                                       new LinkedBlockingQueue<Runnable>(),
5                                       threadFactory);
6     }

可以看出只需要设置两个参数:线程数量和线程工厂(可不传)

1.这里可以看出FixedThreadPool使用的工作队列是无界的链表结构的阻塞队列,所以这里的maximumPoolSize参数就设置成了和coolPoolSize一样的值,因为设置再大也失去了意义;

2.多余线程保持活跃的时间设置成了0,也就是多余的空闲线程会立即终止;

3.由于队列是无界的,所以线程池不会出现拒绝任务的情况,所以也不会用到饱和策略;

4.整体的工作流程就是:

线程池中线程数量少于corePoolSize时会先创建新线程来预热,达到之后就将任务放入LinkedBlockingQueue队列中,线程执行完任务之后会循环从队列中获取任务来执行

2.2、SingleThreadExecutor详解

源码如下:

1 public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {
2         return new FinalizableDelegatedExecutorService
3             (new ThreadPoolExecutor(1, 1,
4                                     0L, TimeUnit.MILLISECONDS,
5                                     new LinkedBlockingQueue<Runnable>(),
6                                     threadFactory));
7     }

可以看出SingleThreadExecutor和FixedThreadPool几乎一样,只是线程只会有一个线程,相比于FixedThreadPool的好处就是可以保证任务的顺序性

2.3、CachedThreadPool详解

源码如下:

1 public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {
2         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
3                                       60L, TimeUnit.SECONDS,
4                                       new SynchronousQueue<Runnable>(),
5                                       threadFactory);
6     }

可以看出也只需要设置线程工厂一个参数,而其他参数都是固定的,corePoolSize设置为0,即corePool为空;maximumPoolSize设置为了Integer的最大值就表示是无大小限制了。keepAliveTime设置成了60秒;队列使用了SynchronousQueue

整体的工作流程为:

1.提交任务到SynchronousQueue队列中,如果线程池中有空余的线程在执行poll操作,则此任务就会被该线程获取执行

2.如果线程池中没有空闲线程,则就会在线程池中创建新的线程来执行poll操作获取任务

3.线程池中的空闲线程如果poll操作没有获取到任务,则会等待60秒,如果没有等待任务则线程终止

所以CachedThreadPool的好处是没有任务的时候,线程池中不需要创建线程等待任务,或者任务执行完之后,线程会在不久就会释放,节省了资源。但是如果任务数量较大,且线程处理任务的速度慢于主线程提交任务的速度,那么线程池中就会不停的创建新线程来执行,

就会有线程数量过多而导致CPU和内存资源被消耗尽的情况

三、FutureTask详解

3.1、FutureTask用法

FutureTask除了实现了Future接口,还实现了Runnable接口,所以FutureTask可以被Executor执行,也可以直接调用本身的run方法执行。

FutureTask有三种状态:未启动(未执行run方法)、已启动(执行run方法中)、已结束(run方法结束或抛出异常)

当FutureTask不是处于已结束状态时,调用get方法会阻塞当前线程知道任务结束;当处于已结束状态时,调用get方法会返回任务执行的结果或抛出对应的异常

当FutureTask处于未启动状态时,调用cancel方法会导致该任务永远不会被执行;

当FutureTask处于已启动状态时,调用cancel(true)方法会中断执行的任务,调用cancel(false)方法将不会对正在执行此任务的线程产生影响

当FutureTask处于已结束状态时,调用cancel方法会返回false

3.2、FutureTask实现原理

FutureTask底层是基于AQS(抽象同步队列)实现的

原文地址:https://www.cnblogs.com/jackion5/p/10663934.html

时间: 2024-10-13 01:51:37

深入浅出JAVA线程池使用原理2的相关文章

深入浅出JAVA线程池使用原理1

前言: Java中的线程池是并发框架中运用最多的,几乎所有需要异步或并发执行任务的程序都可以使用线程池,线程池主要有三个好处: 1.降低资源消耗:可以重复使用已经创建的线程降低线程创建和销毁带来的消耗 2.提高响应速度:执行任务时,不需要等待线程的创建就可以直接执行任务 3.提高线程的可管理性:线程是稀缺资源,如果无限制地创建不仅会消耗系统资源,还会降低系统的稳定性,线程池可以对线程进行统一分配.调优和监控 一.线程池的实现原理 在了解线程池实现原理之前,先了解线程池的一些元素 1.核心线程池

Java 线程池的原理与实现

最近在学习线程池.内存控制等关于提高程序运行性能方面的编程技术,在网上看到有一哥们写得不错,故和大家一起分享. [分享]Java 线程池的原理与实现 这几天主要是狂看源程序,在弥补了一些以前知识空白的同时,也学会了不少新的知识(比如 NIO),或者称为新技术吧.线程池就是其中之一,一提到线程,我们会想到以前<操作系统>的生产者与消费者,信号量,同步控制等等.一提到池,我们会想到数据库连接池,但是线程池又如何呢? 建议:在阅读本文前,先理一理同步的知识,特别是syncronized同步关键字的用

Java线程池的原理及几类线程池的介绍

刚刚研究了一下线程池,如果有不足之处,请大家不吝赐教,大家共同学习.共同交流. 在什么情况下使用线程池? 单个任务处理的时间比较短 将需处理的任务的数量大 使用线程池的好处: 减少在创建和销毁线程上所花的时间以及系统资源的开销 如不使用线程池,有可能造成系统创建大量线程而导致消耗完系统内存以及"过度切换". 线程池工作原理: 为什么要用线程池? 诸如 Web 服务器.数据库服务器.文件服务器或邮件服务器之类的许多服务器应用程序都面向处理来自某些远程来源的大量短小的任务.请求以某种方式到

Java 线程池的原理与实现 (转)

  最近在学习线程池.内存控制等关于提高程序运行性能方面的编程技术,在网上看到有一哥们写得不错,故和大家一起分享. [分享]Java 线程池的原理与实现 这几天主要是狂看源程序,在弥补了一些以前知识空白的同时,也学会了不少新的知识(比如 NIO),或者称为新技术吧.线程池就是其中之一,一提到线程,我们会想到以前<操作系统>的生产者与消费者,信号量,同步控制等等.一提到池,我们会想到数据库连接池,但是线程池又如何呢? 建议:在阅读本文前,先理一理同步的知识,特别是syncronized同步关键字

我眼中的java线程池实现原理

最近在看java线程池实现方面的源码,在此做个小结,因为网上关于线程池源码分析的博客挺多的,我也不打算重复造轮子啦,仅仅用纯语言描述的方式做做总结啦! 个人认为要想理解清楚java线程池实现原理,明白下面几个问题就可以了: (1):线程池存在哪些状态,这些状态之间是如何进行切换的呢? (2):线程池的种类有哪些? (3):创建线程池需要哪些参数,这些参数的具体含义是什么? (4):将任务添加到线程池之后运行流程? (5):线程池是怎么做到重用线程的呢? (6):线程池的关闭 首先回答第一个问题:

11 java 线程池 实现原理

一 关键类的实现 1 ThreadPoolExecutor类 java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类,因此如果要透彻地了解Java中的线程池,必须先了解这个类. 下面我们来看一下ThreadPoolExecutor类的具体实现源码. 在ThreadPoolExecutor类中提供了四个构造方法: 1 public class ThreadPoolExecutor extends AbstractExecutorService {

Java线程池实现原理与技术

本文将通过实现一个简易的线程池理解线程池的原理,以及介绍JDK中自带的线程池ThreadPoolExecutor和Executor框架. 1.无限制线程的缺陷 多线程的软件设计方法确实可以最大限度地发挥多核处理器的计算能力,提高生产系统的吞吐量和性能.但是,若不加控制和管理的随意使用线程,对系统的性能反而会产生不利的影响. 一种最为简单的线程创建和回收的方法类似如下: new Thread(new Runnable() { @Override public void run() { //do s

Java 线程池的原理与实现学习(一)

线程池:    多线程技术主要解决处理器单元内多个线程执行的问题,它可以显著减少处理器单元的闲置时间,增加处理器单元的吞吐能力.        假设一个服务器完成一项任务所需时间为:T1 创建线程时间,T2 在线程中执行任务的时间,T3 销毁线程时间.        如果:T1 + T3 远大于 T2,则可以采用线程池,以提高服务器性能.                一个线程池包括以下四个基本组成部分:                1.线程池管理器(ThreadPool):用于创建并管理线程

Java 线程池的原理与实现学习(二)

摘自:http://www.cnblogs.com/lxzh/archive/2013/01/20/2868736.html execute(Runnable command):履行Ruannable类型的任务 submit(task):可用来提交Callable或Runnable任务,并返回代表此任务的Future对象 invokeAll(collection of tasks):执行给定的任务,当所有任务完成时,返回保持任务状态和结果的 Future 列表. shutdown():在完成已提