文档章节

ThreadPoolExecutor 的理解

暗中观察
 暗中观察
发布于 06/14 08:45
字数 634
阅读 15
收藏 0

公司有位大佬写下这么一段话

 

①,FixedThreadPool任务队列的无边界会导致内存溢出以及高延迟
②,CachedThreadPool线程数的无边界会导致并发高的时候创建的线程数不可控

建议因为两者都不是特别友好,所以推荐直接使用ThreadPoolExecutor,它提供了很多参数可以进行细粒度的控制,

然后我就找了个机会了解下,这是怎么回事

查看ThreadPoolExecutor#execute 方法

简介说,这可能启动新的线程或原有线程开启任务或拒绝任务,代码如下

 public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();        
        int c = ctl.get();
//如何工作的线程数小于核心线程数
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))//新起一个线程并添加到工作队列,然后return
                return;
            c = ctl.get();
        }
        //workQueue.offer将任务添加到工作队列中
        if (isRunning(c) && workQueue.offer(command)) {
            int recheck = ctl.get();
            if (! isRunning(recheck) && remove(command))
                reject(command);
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }
        else if (!addWorker(command, false))
            reject(command);添加到工作队列失败,使用拒绝策略
    }

1,当执行线程数小于核心线程数或阻塞队列满的时候,会尝试直接开启一线程运行任务:addWorker

new Worker 会从线程池中获取新的线程,并保存到一个实例变量中,如下

      Worker(Runnable firstTask) {
            setState(-1); // inhibit interrupts until runWorker
//记录好第一个任务
            this.firstTask = firstTask;
//这里实现线程的重用
            this.thread = getThreadFactory().newThread(this);
        }

线程运行时流程worker.t.start->worker#run->ThreadPoolExecutor#runWorker

会一直从workQueue取出任务,当workQueue为空时,则阻塞获取

2,当执行线程数大于等于核心线程数时,将任务添加到阻塞队列:workQueue.offer(command)

 work工作时会运行runWorker方法,如下

  final void runWorker(Worker w) {
        Thread wt = Thread.currentThread();
        Runnable task = w.firstTask;
        w.firstTask = null;
        w.unlock(); // allow interrupts
        boolean completedAbruptly = true;
        try {
            //不断从工作队列中获取task,并执行,这就是所谓的线程池和工作窃取机制
            while (task != null || (task = getTask()) != null) {
                w.lock();               
                if ((runStateAtLeast(ctl.get(), STOP) ||
                     (Thread.interrupted() &&
                      runStateAtLeast(ctl.get(), STOP))) &&
                    !wt.isInterrupted())
                    wt.interrupt();
                try {
                    beforeExecute(wt, task);
                    Throwable thrown = null;
                    try {
                        task.run();
                    } catch (RuntimeException x) {
                        thrown = x; throw x;
                    } catch (Error x) {
                        thrown = x; throw x;
                    } catch (Throwable x) {
                        thrown = x; throw new Error(x);
                    } finally {
                        afterExecute(task, thrown);
                    }
                } finally {
                    task = null;
                    w.completedTasks++;
                    w.unlock();
                }
            }
            completedAbruptly = false;
        } finally {
            processWorkerExit(w, completedAbruptly);
        }
    }

 

© 著作权归作者所有

上一篇: 桶排序
下一篇: nio/io 拷贝文件
暗中观察

暗中观察

粉丝 7
博文 128
码字总数 45846
作品 0
惠州
私信 提问
多线程 - ThreadPoolExecutor 常用的拒绝策略(RejectedExecutionHandler)

AbortPolicy 该策略是线程池的默认策略。使用该策略时,如果线程池队列满了丢掉这个任务并且抛出RejectedExecutionException异常。源码如下: DiscardPolicy 这个策略和AbortPolicy的slient版...

晨猫
2018/11/26
36
0
Android开发——Android中常见的4种线程池(保证你能看懂并理解)

0.前言 转载请注明出处:http://blog.csdn.net/seu_calvin/article/details/52415337 使用线程池可以给我们带来很多好处,首先通过线程池中线程的重用,减少创建和销毁线程的性能开销。其次...

天王盖地虎626
2018/12/25
275
0
Java多线程之线程池(ThreadPoolExecutor)实现原理分析(一)

在上一篇文章Java中实现多线程的3种方法介绍和比较中,我们讲解了Java中实现多线程的3种方法。使用多线程,就必须要考虑使用线程池,今天我们来聊聊线程池的那些事。 注:源码都是基于JDK1....

小怪聊职场
2018/05/14
0
0
【JDK源码分析】线程池ThreadPoolExecutor原理解析

前言 一般情况下使用线程池都是通过Executors的工厂方法得到的,这些工厂方法又基本上是调用的ThreadPoolExecutor的构造器。也就是说常用到的线程池基本用到的是ThreadPoolExecutor。ThreadP...

还是搬砖踏实
2018/08/05
0
0
深入理解java之线程池

  如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率,因为频繁创建线程和销毁线程需要时间。   那么有没有一种办法使...

snowing1990
2016/08/05
94
0

没有更多内容

加载失败,请刷新页面

加载更多

作为一个(IT)程序员!聊天没有话题?试试这十二种技巧

首先呢?我是一名程序员,经常性和同事没话题。 因为每天都会有自己的任务要做,程序员对于其他行业来说;是相对来说比较忙的。你会经常看到程序员在发呆、调试密密麻麻代码、红色报错发呆;...

小英子wep
今天
14
0
【SpringBoot】产生背景及简介

一、SpringBoot介绍 Spring Boot 是由 Pivotal 团队提供的全新框架,其设计目的是用来简化新 Spring 应用的初始搭建以及开发过程,该框架使用了特定的方式来进行配置,从而使开发人员不再需要...

zw965
今天
5
0
简述并发编程分为三个核心问题:分工、同步、互斥。

总的来说,并发编程可以总结为三个核心问题:分工、同步、互斥。 所谓分工指的是如何高效地拆解任务并分配给线程,而同步指的是线程之间如何协作,互斥则是保证同一时刻只允许一个线程访问共...

dust8080
今天
6
0
OSChina 周四乱弹 —— 当你简历注水但还是找到了工作

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @花间小酌 :#今日歌曲推荐# 分享成龙的单曲《男儿当自强》。 《男儿当自强》- 成龙 手机党少年们想听歌,请使劲儿戳(这里) @hxg2016 :刚在...

小小编辑
今天
3.3K
22
靠写代码赚钱的一些门路

作者 @mezod 译者 @josephchang10 如今,通过自己的代码去赚钱变得越来越简单,不过对很多人来说依然还是很难,因为他们不知道有哪些门路。 今天给大家分享一个精彩的 GitHub 库,这个库整理...

高级农民工
昨天
10
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部