Java线程池ThreadPoolExecutor源码分析 Executor接口 public interface Executor { void execute(Runnable command...线程池监控 如果在系统中大量使用线程池，则有必要对线程池进行监控，方便在出现问题时，可以根据线程池的使用状况快速定位问题。 可以通过线程池提供的参数进行监控，在监控线程池的时候可以使用以下属性。...largestPoolSize：线程池里曾经创建过的最大线程数量。通过这个数据可以知道线程池是否曾经满过。如该数值等于线程池的最大大小， 则表示线程池曾经满过。...getPoolSize：线程池的线程数量。如果线程池不销毁的话，线程池里的线程不会自动销毁，所以这个大小只增不减。 getActiveCount：获取活动的线程数。 通过扩展线程池进行监控。...可以通过继承线程池来自定义线程池，重写线程池的beforeExecute、afterExecute和terminated方法， 也可以在任务执行前、执行后和线程池关闭前执行一些代码来进行监控。
Finalization： 在一个程序中如果不再对线程池进行引用，或者没有剩余的线程，线程池将自动shutdown。...因此线程池最大的线程数量位2^29-1。...结合在第一部分中线程的状态，各状态之间的切换如下图： ? 5.重要方法 在理解了线程池工作的基本原理之后，现在对线程池的一些常用方法进行分析。...之后当线程进入TERMINATION状态的时候统一唤醒。 5.7 getTask 最后再分析一个关键方法。getTask,也就是前面的worker获取任务的方法。这个方法非常重要。...setMaximumPoolSize -> workerCountOf(ctl.get()) > maximumPoolSize setKeepAliveTime 6.总结 本文对ThreadPoolExecutor线程池的源码进行了分析
Java线程池实现原理和源码分析 ? 前言 本文章是从2019年11月下旬开始打开写的，一直拖到2020年的年尾才开始写，直到2021年年初才写完。 时间太快也太慢~！...JDK1.8的源码来分析Java线程池的核心设计与实现。 本文参考了Java线程池实现原理及其在美团业务中的实践这篇文章中的部分内容。...Java线程池实现原理及其在美团业务中的实践这篇文章写的非常好，除过本文内容之外这篇文章还讲述了的关于线程池的背景，线程池在业务中的实践和动态化线程池等，所以想了解线程池关于这些类容的可以阅读Java线程池实现原理及其在美团业务中的实践这篇文章...如果读者为做服务端开发的同学那么强烈建议阅读Java线程池实现原理及其在美团业务中的实践。 外观 外观主要是我们平常使用线程池的时候所看到的一些点。...interruptIdleWorkers 方法在动态调整线程池大小部分有源码讲述，它只会中断空闲的线程，不会中断正在执行任务的的线程。空闲的线程将会阻塞在线程池的阻塞队列上。
Java线程池实现原理和源码分析 [dc61b582844cf193af46b8f90f480960.png#pic_center] 前言 本文章是从2019年11月下旬开始打开写的，一直拖到2020年的年尾才开始写...JDK1.8的源码来分析Java线程池的核心设计与实现。 本文参考了Java线程池实现原理及其在美团业务中的实践这篇文章中的部分内容。...Java线程池实现原理及其在美团业务中的实践这篇文章写的非常好，除过本文内容之外这篇文章还讲述了的关于线程池的背景，线程池在业务中的实践和动态化线程池等，所以想了解线程池关于这些类容的可以阅读Java线程池实现原理及其在美团业务中的实践这篇文章...如果读者为做服务端开发的同学那么强烈建议阅读Java线程池实现原理及其在美团业务中的实践。 外观 外观主要是我们平常使用线程池的时候所看到的一些点。...interruptIdleWorkers 方法在动态调整线程池大小部分有源码讲述，它只会中断空闲的线程，不会中断正在执行任务的的线程。空闲的线程将会阻塞在线程池的阻塞队列上。
本文源自 公-众-号 IT老哥 的分享 IT老哥，一个在大厂做高级Java开发的程序员，每天分享技术干货文章 前言 多线程是我们日常工作中很少能接触到的技术，但是面试的时候100%会被问到，万一工作中用到了基本不会...，本篇咱们就来深入分析线程池的实现类ThreadPoolExecutor。...此处就是为什么《阿里巴巴 Java 开发手册》中不推荐使用Executors工具类创建线程池的原因，要求使用 ThreadPoolExecutor 构造函数的方式，让写的同学更加明确线程池的运行规则，规避资源耗尽的风险...对照流程图，我们再来看源码： //ctl中存放的是int值，int值得高低位保存了线程池运行的状态和有效线程的数量 private final AtomicInteger ctl = new AtomicInteger...workerStarted) addWorkerFailed(w); } return workerStarted; } 5、shutdown方法 线程池不用了，要关闭线程池，下面是源码： public
说明 对于JDK源码分析的文章，仅仅记录我认为重要的地方。源码的细节实在太多，不可能面面俱到地写清每个逻辑。...所以我的JDK源码分析，着重在JDK的体系架构层面，具体源码可以参考：http://www.cnblogs.com/skywang12345/category/455711.html。 架构图 ?...分析： 示例代码中，新建了一个大小固定为2的线程池，并将5个线程依次放入线程池。...，线程池的容量是nThreads。...ctl记录了"线程池中的任务数量"和"线程池状态"2个信息。 ctl共包括32位。其中，高3位表示"线程池状态"，低29位表示"线程池中的任务数量"。
private static final int CAPACITY = (1 << COUNT_BITS) - 1; 不得不佩服写 JDK 源码这些大佬，把一个变量用的这么好，ctl 变量通过位运算同时表达了线程池状态和线程个数...然后再次执行任务）、DiscardPolicy（直接抛弃任务） keepAliveTime：存活时间，当线程个数大于了核心线程数，且处于空闲状态，这些空闲线程可存活的最大时间 源码拆解...因为 Woker 的构造器是通过线程工厂创建的线程，分析如下 Worker(Runnable firstTask) { setState(-1); // inhibit interrupts until...w); } finally { mainLock.unlock(); } // 尝试把线程池的状态设置为 TERMINATED，该方法在后面分析 tryTerminate...参考资料 https://juejin.im/entry/59b232ee6fb9a0248d25139a 《Java异步编程实战》
线程池能有效管控线程，统一分配、调优，提供资源使用率； 更强大的功能，线程池提供了定时、定期以及可控线程数等功能的线程池，使用方便简单。...二、线程池用法 Java API针对不同需求，利用Executors类提供了4种不同的线程池：newCachedThreadPool, newFixedThreadPool, newScheduledThreadPool...4.2 线程池监控 利用线程池提供的参数进行监控，参数如下： taskCount：线程池需要执行的任务数量。...largestPoolSize：线程池曾经创建过的最大线程数量，通过这个数据可以知道线程池是否满过。如等于线程池的最大大小，则表示线程池曾经满了。 getPoolSize：线程池的线程数量。...五、参考资料 Java线程池源码剖析(ThreadPoolExecutor) 线程池里的大学问：分析Java线程池的创建 聊聊并发（三）Java线程池的分析和使用
创建一个线程 在Java的并发编程中，线程是十分重要的，在Java中，创建一个线程比较简单： ? 我们通过创建一个线程对象，并且实现Runnable接口就可以实现一个简单的线程。可以利用上多核CPU。...这也就是池化技术的思想，通过预先创建好多个线程，放在池中，这样可以在需要使用线程的时候直接获取，避免多次重复创建、销毁带来的开销。 线程池的简单使用 以下代码，是在Java中创建线程池： ?...可以看到，开发者想要在代码中使用线程池还是比较简单的，这得益于Java给我们封装好的一系列API。但是，这些API的背后是什么呢，让我们来揭开这个迷雾，看清线程池的本质。...这个是java中的goto语法。只能运用在break和continue后面。 接着看后面的代码： ? 第一个红框：获取线程池主锁。...这两个钩子（beforeExecute，afterExecute）允许我们自己继承线程池，做任务执行前后处理。 到这里，源代码分析到此为止。接下来做一下简单的总结。
概述 在 java 中，线程池 ThreadPoolExecutor 是一个绕不过去的类，它是享元模式思想的体现，通过在容器中创建一定数量的线程加以重复利用，从而避免频繁创建线程带来的额外开销。...一个设置合理的线程池可以提高任务响应的速度，并且避免线程数超过硬件能力带来的意外情况。 在本文，将深入线程池源码，了解线程池的底层实现与运行机制。...，任务会优先加入工作队列，等等待核心线程消费； 线程工厂：线程池创建新线程时使用的线程工厂； 拒绝策略：当工作队列与线程池都满时，用于执行的策略； 二、线程池状态 1.线程池状态 线程池拥有一个 AtomicInteger...private static final int TERMINATED = 3 << COUNT_BITS; 2.线程状态的计算 这里比较不好理解的是上述-1的位运算，下面我们来分析一下： 在计算机中...，二进制负数一般用补码表示，即源码取反再加一。
这种情况下getException返回java.util.concurrent.CancellationException和isCompletedAbnormally。...如果任务是已取消的或者遇到异常，在这种情况下，getException将返回所遇到的异常或者java.util.concurrent.CancellationException。...当所有任务都具有这种形式的时候，请考虑使用asyncMode 中构造的池。...或者调用isDone，否则，执行该任务的状态或执行该操作的任何数据的后续修改不一定可由执行该任务的线程以外的任何线程一致地观察到。...另外，任何ForkJoinPool中的某个线程在其池变为isQuiescent时都会调用helpExpungeStaleExceptions static final class ExceptionNode
在前面介绍了ForkJoinPool的骨架源码之后，我们来看看ForkJoinPool的核心组成。WorkQueue的源码。...config int 用于存储线程池的index和model qlock volatile int 1 表示锁定，小于0的时候表示结束，线程池的其他状态下这个值都应该为0 base volatile...3.9 runTask 在之前的文章分析外部提交task的时候，就提到了这个方法。实际上是runWorker调用的。 也就是说，线程在启动之后，一旦worker获取到task，就会运行。...break; } } } } return h; } 4.总结 本文对workQueue的源码进行了分析...至此，我们分析了workQueue的源码，对其内部实现的双端队列本身的操作进行了分析。为什么作者会自己实现一个Deque，而不是使用juc中已存在的容器。
ForkJoinWorkerThread继承了Thread类，其注释大意如下： ForkJoinWorkerThread是由ForkJoinPool管理的线程，该线程执行ForkJoinTask。...其中registerWorker与deregisterWorker方法 ，我们可以参考前面的ForkJoinPool源码解读。...此类定义了一个没有任何权限、也非用户定义的任何线程组的线程。这个线程在运行完每个top的task之后，会擦除所有的ThreadLocals。 ?...源码如下： static final class InnocuousForkJoinWorkerThread extends ForkJoinWorkerThread { /** The ThreadGroup...( new java.security.PrivilegedAction() { public
前提 很早之前就打算看一次JUC线程池ThreadPoolExecutor的源码实现，由于近段时间比较忙，一直没有时间整理出源码分析的文章。...工作线程，内部类Worker类型，是线程池中真正的工作线程对象。 关于AQS笔者之前写过一篇相关源码分析的文章：JUC同步器框架AbstractQueuedSynchronizer源码图文分析。...源码分析 先分析线程池的关键属性，接着分析其状态控制，最后重点分析ThreadPoolExecutor#execute()方法。...execute方法源码分析 线程池异步执行任务的方法实现是ThreadPoolExecutor#execute()，源码如下： // 执行命令，其中命令（下面称任务）对象是Runnable的实例 public...，后面将会编写两篇文章分别详细分析线程池扩展服务ExecutorService的功能源码实现以及调度线程池ScheduledThreadPoolExecutor的源码实现，预计要耗时2-3周。
在日常的开发工作当中，线程池往往承载着一个应用中最重要的业务逻辑，因此我们有必要更多地去关注线程池的执行情况，包括异常的处理和分析等。本文主要聚焦在如何正确使用线程池上，以及提供一些实用的建议。...答案是没有影响，线程池依旧可以正常工作，但是异常却被吞掉了。这通常来说不是一个好事情，因为我们需要拿到原始的异常对象去分析问题。 那么怎样才能拿到原始的异常对象呢？...我们从线程池的源码着手开始研究这个问题。...当然网上关于线程池的源码解析文章有很多，这里限于篇幅，直接给出最相关的部分代码： finalvoidrunWorker(Workerw){Threadwt=Thread.currentThread();...通过submit提交任务到线程池 这个同样很简单，我们还是先回到submit方法的源码： publicFuturesubmit(Callabletask){if(task==null)
通过使用这些工具类，我们可以用低廉的代价使用多线程技术。 线程池作为 Java 并发重要的工具类，在会用的基础上，我觉得很有必要去学习一下线程池的相关原理。...3.原理分析 3.1 核心参数分析 3.1.1 核心参数简介 如上节所说，线程池的核心实现即 ThreadPoolExecutor 类。该类包含了几个核心属性，这些属性在可在构造方法进行初始化。...具体细节这里就不多说了，并不复杂，大家可以自己去看下源码。 在线程池中，线程的复用是线程池的关键所在。这就要求线程在执行完一个任务后，不能立即退出。...在本文中，我对线程池的主要原理做了简要分析。虽然只是简要分析，但通过分析并撰写此篇文章，也使我个人对 Java 线程池有了更深的认识。需要说明的是，限于时间原因，本文并未将线程池所有的知识都说一遍。...参考 聊聊并发（三）Java线程池的分析和使用 - 方腾飞 深入理解Java之线程池 - 海子 Java多线程18：线程池 - 五月的仓颉 本文在知识共享许可协议 4.0 下发布，转载需在明显位置处注明出处
通过使用这些工具类，我们可以用低廉的代价使用多线程技术。 线程池作为 Java 并发重要的工具类，在会用的基础上，我觉得很有必要去学习一下线程池的相关原理。...原理分析 核心参数分析 核心参数简介 核心实现即 ThreadPoolExecutor 类。该类包含了几个核心属性，这些属性在可在构造方法进行初始化。...默认是 AbortPolicy，即直接抛出异常 线程创建规则 在 Java 线程池实现中，线程池所能创建的线程数量受限于 corePoolSize 和 maximumPoolSize 两个参数值。...Java 线程池提供了4中拒绝策略实现类，如下： 实现类 说明...几种线程池 在阿里巴巴Java开发手册中明确指出禁止使用Executors 工具类创建线程。
一、前言 线程是稀缺资源，如果被无限制的创建，不仅会消耗系统资源，还会降低系统的稳定性，合理的使用线程池对线程进行统一分配、调优和监控，有以下好处：重用存在的线程、可有效控制最大并发线程数 二、怎么做...3.再次判断判断当前线程池状态，如果线程池没有RUNNING，且成功从阻塞队列中删除任务，则执行reject方法处理任务； 4.如果当前线程数等于0的极端情况下，可能出现一个任务刚被插入队列的同时，所有的线程都结束任务然后被销毁了...Worker 添加到workers hashset中，最后开始启动Worker中的线程t.start()，源码中 this.thread = getThreadFactory().newThread(this...回顾代码，好像也没有直接体现复用线程池的，Worker每次都是new。...看整个线程池的工作流程，有以下几个需要特别关注的并发点. 线程池状态和工作线程数量的变更。这个由一个AtomicInteger变量 ctl来解决原子性问题。
源码讲解 在ThreadPoolExecutor的属性定义中频繁地用位运算来表示线程池状态; 位运算是改变当前值的一种高效手段....下面继续分析addWorker addWorker 源码解析 根据当前线程池状态,检查是否可以添加新的任务线程,若可以则创建并启动任务; 若一切正常则返回true; 返回false的可能性如下 线程池没有处于...总结 线程池的相关源码比较精炼，还包括线程池的销毁、任务提取和消费等，与线程状态图一样，线程池也有自己独立的状态转化流程，本节不再展开。...Java5后推出的ThreadPoolExecutor的如下构造函数 Java默认提供的线程池 Java中的线程池是运用场景最多的并发框架,几乎所有需要异步或并发执行任务的程序都可以使用线程池...corePoolSize),几乎所有的execute()方法调用都是执行步骤2,而步骤2不需要获取全局锁 #源码分析 /** * 检查是否可以根据当前池状态和给定的边界（核心或最大)
下面从属性定义开始阅读ThreadPoolExecutor的源码。...，最左边3位表示线程池状态。...下面分析ThreadPoolExecutor关于execute的实现。...c) < corePoolSize) { //addWorker 是另一个极为重要的方法，见下一段源码分析（第1处） if (addWorker(command...下面继续分析addWorker 源码。 /** * 根据当前线程池状态，检查是否可以添加新的任务线程，如果可以则创建并启动任务 * 如果一切正常则返回true。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
