栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java实现线程

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java实现线程

实现线程的方法:

1、继承Thread类

2、实现runnable接口(没有返回值,不抛异常) 实现run方法

3、实现callable接口(有返回值,要抛异常)实现call方法

下面为线程池的三个线程的方法:

4、Executors.newFixedThreadPool(int)   固定数量线程池;--执行长期的任务,性能好很多

      Executors.newSingleThreadPool()     单个线程线程池   ----一个任务一个任务执行的场景

      Executors.newCachedThreadPool()    多个线程线程池(系统自动的根据任务安排数量)适用于:执行很多短期异步的小程序或者负载较轻的服务器

以上三个都是由ThreadPoolExecutor方法实现:该方法有一下七个参数:

corePoolSize:线程池中常驻核心线程数量

maximumPoolSize:线程池能够容纳同时执行的最大线程数量,此值必须大于等于1

keepAliveTime:多余的空闲线程的存活时间。(当前线程池数量超过corePoolSize时,当空闲时间达到了keepAliveTime值时,多余空闲线程会被销毁直到只剩下corePoolSize个线程为止。

unit :keepAliveTime 的单位

workQueue:任务队列,被提交但尚未被执行的任务。

threadFactory:表示生成线程池中工作线程的线程工厂,用于创建线程,一般用默认的即可

handler:拒绝策略,表示当队列满了并且工作线程大于等于线程池最大的线程数时,如何来拒绝请求执行的runnable策略。

线程池的底层工作原理:

1、在创建了线程池之后,等待提交过来的任务请求。

2、当调用execute()方法添加一个请求任务时,线程会做如下判断:

        2.1 如果正在运行的线程数量小于corePoolSize,那么马上创建线程运行这个任务;

        2.2 如果正在运行的线程数量大于或等于maximumPoolSize,那么将这个任务放入队列;

        2.3 如果这时候队列满了且正在运行的线程数量还小于maximumPollSize,那么还是要创建非核心线程来立刻处理这些任务。

        2.4 如果队列满了且正在运行的线程数量大于等于maximumPoolSize,那么线程池会启动饱和拒绝策略来执行。

3、当一个线程完成任务时,它会从队列中取下一个任务来执行

4、当一个线程无事情可以做超过一定的时间(keepAliveTime)时候,线程池会判断:如果当前运行的线程数量大于corePoolSize,那么这个线程就被停掉。所以线程池所有任务完成后它最终会收缩到corePoolSize的大小。

线程池的四种拒绝策略:它是等待队列已经满了,再也塞不下新任务了,同时线程池中的max线程也已经达到了,无法继续为新任务服务。这时候我们就需要拒绝策略机制合理的处理这个问题。JDK提供的4中拒绝策略如下:

AbortPolicy(默认):直接抛出RejectedExecutionException异常阻止系统正常运行。

CallerRunsPolicy:”调用者运行”一种调节机制,该策略不会抛弃任务,也不会抛出异常,而是将塞不下的任务退回到调用线程池的线程去完成。相当于退回到调用者

DiscardOldestPolicy:抛弃队列中等待最久的任务,然后把当前任务加入队列中尝试再次提交当前任务。

DiscardPolicy:直接丢弃任务,不予以任何处理也不抛出异常,如果允许任务丢失,这是最好的方案。

在实际生产中选择三种线程池(fixed/single/cache):请回答以上三个全都不适合,生产中需要自行定义。

原因是:fixed/single/cache,在声明的时候线程池的队列参数时用的阻塞queue最大数能达到21亿多,等待队列太大了。Alibaba手册中强调了线程池不允许使用Executors去创建,而需要通过ThreadPoolExecutor的方式,这样的方式让写的人更加明确线程池的运行规则,避免资源耗尽的风险。

 

 Alibaba手册中还强调线程资源必须通过线程池提供,不允许在应用中自行显示创建线程

线程池配置合理的线程数量: 

主要考虑你的业务是什么形的:一般有CPU密集型  或者  IO密集型

CPU密集型的线程数量公式:CPU核数+1个线程         

  

IO密集型的公式有两种:

        第一种:CPU核数*2

        第二种:CPU核数/1-阻塞系数  阻塞系数在0.8-0.9之间

​​​​​​​ 

 

runtime.getruntime().availableProcessors()  查看CPU的核数

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/293399.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号