java并发编程笔记(七)——线程池

  • new Thread弊端

    • 每次new Thread新建对象,性能差
    • 线程缺乏统一管理,可能无限制的新建线程,相互竞争,有可能占用过多系统资源导致死机或者OOM
    • 缺少更多功能,如更多执行、定期执行、线程中断
  • 线程池的好处
    • 重用存在的线程,减少对象创建、消亡的开销,性能佳
    • 可有效控制最大并发线程数,提高系统资源利用率,同时可以避免过多资源竞争,避免阻塞
    • 提供定时执行、定期执行、单线程、并发数控制等功能

ThreadPoolExecutor

重要核心参数

  • corePoolSize:核心线程数量

  • maximuPoolSize:线程池最大线程数

  • workQueue:阻塞队列,存储等待执行的任务,很重要,会对线程池运行过程产生重大影响

  • keepAliveTime:线程没有任务执行的时候最多保持多久时间终止,比如任务量低于核心线程数的时候,线程需要再等待多久才可以释放掉线程

  • unit:keepAliveTime的时间单位

  • threadFactory:线程工厂,用来创建线程,能够使创建的线程具有相同的优先级,并且是非守护的线程,同时也设置了线程的名称,

  • rejectHandler:当拒绝处理任务时的策略

    • 直接抛出异常
    • 用调用者所在的线程来执行任务
    • 丢弃队列中最靠前的任务来释放线程执行当前任务
    • 直接丢弃当前任务

线程池的五种状态

  • RUNNING:能够接受新提交的任务,也能处理阻塞队列中的任务,

  • (pool.shutdown())SHUTDOWN:关闭状态,不能接受新提交的任务,但是能够处理阻塞队列中保存的任务

  • (pool.shutdownNow())STOP:不能接受新的任务,也不能处理阻塞队列中的任务,会中断正在处理中的线程。

  • TIDYING:阻塞队列为空,线程池中的工作线程数为0

  • (pool.terminated()) TERMINATED

线程池的相关方法

  • execute():提交任务,交给线程池执行

  • submit():提交任务,能够返回执行结果 execute + Future

  • shutdown():关闭线程池,等待任务都执行完

  • shutdownNow():关闭线程池,不等待任务执行完

  • getTaskCount():线程池已执行和未执行的任务总数

  • getCompletedTaskCount():已完成的任务数量

  • getPoolSize():线程池当前的线程数量

  • getActiveCount():当前线程池中正在执行任务的线程数量

Executor框架接口

  • Executors.newCachedThreadPool

  • Executors.newFixedThreadPool

  • Executors.newScheduledThreadPool

    @Slf4j
    public class ThreadPoolExample4 { public static void main(String[] args) { ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1); // executorService.schedule(new Runnable() {
    // @Override
    // public void run() {
    // log.warn("schedule run");
    // }
    // }, 3, TimeUnit.SECONDS); executorService.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
    log.warn("schedule run");
    }
    }, 1, 3, TimeUnit.SECONDS);
    // executorService.shutdown(); Timer timer = new Timer();
    timer.schedule(new TimerTask() {
    @Override
    public void run() {
    log.warn("timer run");
    }
    }, new Date(), 5 * 1000);
    }
    }
  • Executors.newSingleThreadExecutor

线程池的合理配置

  • CPU密集型任务,就需要尽量压榨CPU,参考值可以设置为N(cpu) + 1
  • IO密集型任务,参考值可以设置为2*N(cpu)

java并发编程笔记(七)——线程池的更多相关文章

  1. 【Java并发编程六】线程池

    一.概述 在执行并发任务时,我们可以把任务传递给一个线程池,来替代为每个并发执行的任务都启动一个新的线程,只要池里有空闲的线程,任务就会分配一个线程执行.在线程池的内部,任务被插入一个阻塞队列(Blo ...

  2. Java并发编程笔记4-线程池

    我们使用线程的时候就去创建一个线程,但是就会有一个问题: 如果并发的线程数量非常多,而且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会导致大大降低系统的效率,因为频繁创建线程和销毁线 ...

  3. Java并发编程 (九) 线程调度-线程池

    个人博客网:https://wushaopei.github.io/    (你想要这里多有) 声明:实际上,在开发中并不会普遍的使用Thread,因为它具有一些弊端,对并发性能的影响比较大,如下: ...

  4. java并发编程笔记(五)——线程安全策略

    java并发编程笔记(五)--线程安全策略 不可变得对象 不可变对象需要满足的条件 对象创建以后其状态就不能修改 对象所有的域都是final类型 对象是正确创建的(在对象创建期间,this引用没有逸出 ...

  5. java并发编程笔记(三)——线程安全性

    java并发编程笔记(三)--线程安全性 线程安全性: ​ 当多个线程访问某个类时,不管运行时环境采用何种调度方式或者这些进程将如何交替执行,并且在主调代码中不需要任何额外的同步或协同,这个类都能表现 ...

  6. java并发编程笔记(九)——多线程并发最佳实践

    java并发编程笔记(九)--多线程并发最佳实践 使用本地变量 使用不可变类 最小化锁的作用域范围 使用线程池Executor,而不是直接new Thread执行 宁可使用同步也不要使用线程的wait ...

  7. Java并发编程系列-(2) 线程的并发工具类

    2.线程的并发工具类 2.1 Fork-Join JDK 7中引入了fork-join框架,专门来解决计算密集型的任务.可以将一个大任务,拆分成若干个小任务,如下图所示: Fork-Join框架利用了 ...

  8. java并发编程笔记(十)——HashMap与ConcurrentHashMap

    java并发编程笔记(十)--HashMap与ConcurrentHashMap HashMap参数 有两个参数影响他的性能 初始容量(默认为16) 加载因子(默认是0.75) HashMap寻址方式 ...

  9. java并发编程笔记(八)——死锁

    java并发编程笔记(八)--死锁 死锁发生的必要条件 互斥条件 进程对分配到的资源进行排他性的使用,即在一段时间内只能由一个进程使用,如果有其他进程在请求,只能等待. 请求和保持条件 进程已经保持了 ...

随机推荐

  1. Smart3D系列教程7之 《手动配置S3C索引加载全部的瓦片数据》

    一.前言 迄今为止,Wish3D已经出品推出了6篇系列教程,从倾斜摄影的原理方法.采集照片的技巧.Smart3D各模块的功能应用.小物件的照片重建.大区域的地形重建到DSM及正射影像的处理生产,立足于 ...

  2. C++ dynamic_cast对指针类型的转换

    C8-3 三角形还是长方形? (100.0/100 points) 题目描述 在多态概念中,基类的指针既可以指向基类的对象,又可以指向派生类的对象.我们可以使用dynamic_cast类型转换操作符来 ...

  3. sql server 2008安装过程中服务器配置出错

    请选择:对所有 SQL Server 服务使用相同的账号: 但这里不能给他设置自己定义的账号和密码 ( 例如下面设置它的账号为 sa ,密码为 654321) 就会发生错误:

  4. shell脚本 -d 是目录文件,那么-e,-f分别是什么?还有"! -e"这又是什么意思呢?

    -e filename 如果 filename存在,则为真-d filename 如果 filename为目录,则为真 -f filename 如果 filename为常规文件,则为真-L filen ...

  5. Play on Words(有向图欧拉路)

    Time Limit: 1000MS   Memory Limit: 10000K Total Submissions: 8571   Accepted: 2997 Description Some ...

  6. AutoTile 自动拼接 番外篇(自动融合技术)

    http://pan.baidu.com/s/1dDQyfSl 密码:ttud 先睹为快吧. 之后 还差一个 智能替换 技术.

  7. 转:常用的iOS开源库和第三方组件

    1.通过CocoaPods安装:

  8. 信号处理——傅里叶变换(FT-DTFT-DFT)

    作者:桂. 时间:2017-01-17  23:41:13 链接:http://www.cnblogs.com/xingshansi/articles/6294111.html 声明:转载请注明出处, ...

  9. java.lang.NoSuchMethodError: com.itextpdf.text.pdf.PdfDiv.setKeepTogether(Z)V

    用com.itextpdf.text.Document打印pdf报错 时间:2017-06-22 12:23:39,594 - 级别:[ERROR] - 消息: [other] Servlet.ser ...

  10. Spring再接触 Annotation part2

    resource resource beans.xml <?xml version="1.0" encoding="UTF-8"?> <bea ...