java线程池使用(一)
多线程是程序开发的必经之路,裸线程是不安全的也是不可控制的,因此接入线程池很有必要
一 首先了解下线程池ThreadPoolExecutor 几个参数的概念
1 int corePoolSize 线程池核心线程数
2 int maximumPoolSize 线程池最大线程数
3 long keepAliveTime 空闲线程保持时间
4 TimeUnit unit 时间单位
5 BlockingQueue workQueue 等待线程队列
6 ThreadFactory threadFactory 创建线程池线程的工厂( 注意,是创建线程池线程的工厂,不是创建执行线程的工厂,创建于线程池核心线程初始化和线程队列满导致创建非核心线程时调用 )
7 RejectedExecutionHandler handler 饱和策略,线程池线程达到最大数量,线程队列满时执行的策略
二 线程池线程状态修改策略
三 线程池的使用
1 阿里开发文档中,要求禁止使用Executors 直接创建线程池,是因为Executors 提供的方法在创建线程池时,workQueue ,corePoolSize ,maximumPoolSize 不可控,有可能导致OOM ,
2 因此建议使用ThreadPoolExecutor 创建线程池,根据业务场景选择合适的maximumPoolSize,
3 建议使用单例模式进行线程池的创建,保证一个服务中每一个线程池仅被初始化一次
public class ThreadPoolManager { private static ThreadPoolExecutor instance; public static ThreadPoolExecutor getInstance() { if (instance == null) { synchronized (ThreadManager.class) { if (instance == null) { int cpuNum = Runtime.getRuntime().availableProcessors();// 获取处理器数量 int threadNum = cpuNum * 2 + 1;// 根据cpu数量,计算出合理的线程并发数 int corePoolSize = cpuNum * 2; int maximumPoolSize = corePoolSize + 1; long keepAliveTime = 60l; instance = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime, TimeUnit.MILLISECONDS,new ArrayBlockingQueue<>(300),Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy()); } } } return instance; } }
四 线程池参数选择
1 corePoolSize 业务分为cpu密集型和io密集型,一般web应用都是io密集型,cpu密集型如数学计算,视频编解码等
java 可以使用int cpuNumber = Runtime.getRuntime().availableProcessors() 获取部署机器的cpu核心数(Intel cpu获取的是xianchengshu)线程数
cpu密集型业务corePoolSize = cpuNumber io密集型业务corePoolSize = cpuNumber*2 ,
2 maximumPoolSize 根据业务场景选择 一般 maximumPoolSize = corePoolSize +1
在业务存在偶尔短时间需要处理大量业务时,可以适当放大maximumPoolSize 的值,在短时间内增加并发数量处理业务
3 keepAliveTime 非核心线程空闲时间,根据自己业务,如果maximumPoolSize = corePoolSize 应该设置为0,
如果需要maximumPoolSize >corePoolSize 则需要根据实际业务场景,选择非核心线程的时间,根据newCachedThreadPool的构造函数看,可以设置为60s,在短时间处理洪峰业务处理时,减少线程创建带来的性能消耗,同时在高并发业务处理完成后能及时释放线程资源
4 unit 时间单位,配合keepAliveTime使用
5 workQueue 的选择 ArrayBlockingQueue和LinkedBlockingQueue 的区别请见另一篇博客ArrayBlockingQueue 和LinkedBlockingQueue 代码解析(JDK8)
6 threadFactory 创建线程池线程的工厂,也就是申请线程资源的工厂,执行线程(执行任务)的创建和这个无关,如果对线程资源申请没有特殊需求,可以使用默认的Executors.defaultThreadFactory(),如果想查看线程池什么时候申请了线程资源,比如非核心线程的创建,可以实现ThreadFactory 并重写newThread方法,可以记录线程资源申请时间和线程信息,在非核心线程被回收后,再次申请线程资源时,也是通过threadFactory进行重新创建线程
public class TThreadFactory implements ThreadFactory { @Override public Thread newThread(Runnable r) { System.out.println(new Date()); Thread t= new Thread(r,"new Thread "); return t; } }
7 handler 饱和策略 也就是当线程池没有没有空余线程,线程等待队列满,并且线程池线程数量等于最大线程数,执行饱和策略
饱和策略分为4种
(1)AbortPolicy 直接抛出异常,并抛弃该线程任务,不影响主线程和正在执行和等待的线程
可以使用ThreadPoolExecutor中的AbortPolicy进行创建
new ThreadPoolExecutor.AbortPolicy() {// 队列已满,而且当前线程数已经超过最大线程数时的异常处理策略 @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { super.rejectedExecution(r, e); } }
(2)CallerRunsPolicy 在线程池执行饱和策略时,由主线程执行子线程任务,也就是说,主线程execute()或者submit()被调用后,主线程执行子线程任务,主线程任务挂起等待子线程任务结束后继续执行
ThreadPoolExecutor中的CallerRunsPolicy 进行创建
(3) DiscardPolicy 线程池饱和后,抛弃所有新增的线程
ThreadPoolExecutor中的DiscardPolicy 进行创建
(4)DiscardOldestPolicy 抛弃queue中最老的线程任务,将新任务添加到queue的底部,抛弃掉的任务将不会执行
ThreadPoolExecutor中的DiscardOldestPolicy 进行创建
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
通过PHP与Python代码对比浅析语法差异
一、背景 人工智能这几年一直都比较火,笔者一直想去学习一番;因为一直是从事PHP开发工作,对于Python接触并不算多,总是在关键时候面临着基础不牢,地动山摇的尴尬,比如在遇到稍微深入些的问题时候就容易卡壳,于是准备从Python入门从头学起; 笔者觉得应该有不少人同样熟悉PHP或者Python语言,对另外一个门语言并不是太熟悉,有想法学习另外一门语言,希望通过这篇文章能够对大家有一点帮助。 二、知识点 最近在完成一个小作业,题目要求:通过Python代码实现,让用户输入用户名密码,认证成功后显示欢迎信息,输错三次后退出程序。 在这篇文章当中,会通过这个小作业来总结和分析PHP与Python的语法区别,主要涉及到以下几个知识点: 代码整体风格 变量命名规范 常量命名规范 注释方式 数据类型 输入输出 if语句使用 while循环 三、Python语法 在Python中需要严格遵守空格缩进,否则会报错;在每行代码后面不需要使用;,结构体的条件不需要使用(),执行体里面则不需要{}; 3.1 代码示例 # -*- coding: utf-8 -*- n = 0 while n < 3...
- 下一篇
突破Java面试(38)-分布式服务接口的幂等性
1 面试题 分布式服务接口的幂等性如何设计(比如不能重复扣款)? 2 考点分析 从这开始,面试官就已经进入了实际的生产问题的面试了 一个分布式系统中的某个接口,要保证幂等性,如何保证?这个事,其实是你做分布式系统的时候必须要考虑的一个生产环境的技术问题.为什么呢? 假如你有个服务提供一个接口,这服务部署在5台机器上,有个付款接口.然后用户在前端操作时,不知为啥,一个订单不小心发起了两次支付请求,然后这俩请求分散在了这个服务部署的不同的机器上,这下好了,结果一个订单扣款扣两次,尴尬了! 或者是订单系统调用支付系统进行支付,结果不小心网络超时,然后订单系统走了前面我们看到的那个重试机制,给你重试了一把,好,支付系统收到一个支付请求两次,而且因为负载均衡算法落在了不同的机器上,尴尬了! 所以你肯定得知道这事儿,否则你做出来的分布式系统恐怕容易埋坑! 网
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- CentOS7安装Docker,走上虚拟化容器引擎之路
- SpringBoot2更换Tomcat为Jetty,小型站点的福音
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS8编译安装MySQL8.0.19
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- CentOS关闭SELinux安全模块