Java线程池和Executor框架-面试与分析

2024-09-07 23:44

本文主要是介绍Java线程池和Executor框架-面试与分析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

线程池

什么是线程池?为什么要用线程池?

在Java并发框架中,线程池时使用最多的东西,几乎所有需要异步并发执行任务的程序都可以使用线程池。
使用线程池带来的好处:

  • 降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的损耗
  • 提高响应时间。当任务到达时,任务可以不需要等待线程创建就可以立即执行
  • 提高线程的可管理性。线程是稀缺资源,如果无限创建,会降低系统的稳定性,使用线程可以进行统一分配,调优和监控。

核心参数有哪些?

源代码
7个参数:
corePoolSize:核心线程池的大小
maximumPoolSize:线程池能创建线程的最大数
keepAliveTime:空闲线程存货时间
unit:时间单位,为keepAliveTIme指定时间单位
workQueue:阻塞队列,用于保存任务的阻塞队列
threadFactory:创建线程的工程类
handler:饱和策略**(拒绝策略)**

常用线程池的区别及特点?

  1. newCachedThreadPool(无限池)
  • 特点:newCachedThreadPool创建了一个可缓存线程池,如果当前线程池的长度超过了处理的需要时,它可以灵活的回收空闲的线程,当需要增加时,它可以灵活的添加新的线程,而不会对池的长度做任何限制
  1. newFixedThreadPool(固定)
  • 特点:创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列 中等待。定长线程池的大小需要根据系统 资源进行设置
  • 缺点:线程数量是固定的,但是阻塞队列是无界队列。如果有很多请求积压,阻塞队列越来越长,容易导致OOM(超出内存空间)
  1. newScheduledThreadPool
  • 特点:创建一个固定长度线程池,而且支持定时的以及周期性的任务执行,类似于Timer
  • 缺点:同样是使用无界队列。如果有很多请求积压,阻塞队列越来越长,容易导致OOM
  1. newSingleThreadExecutor
  • 特点:创建一个单线程话的线程池,它只会用唯一的工作线程来执行任务,如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代他,必须保证所有任务按照指定顺序(FIFO)执行。
  • 缺点:很明显,他是单线程的,高并发业务下不行

在Java中Executor和Executors的区别?

Executors工具类的不同方法按照我们的需求创建不同的线程池,来满足业务的需求。
Executor接口对象能执行我们的线程任务
ExecutorService接口继承了Executor接口并进行了扩展,提供了更多的方法我们能获得任务执行的状态并且可以获取任务的返回值。

线程池都有哪些状态?

在这里插入图片描述
RUNNING:这是最正常的状态,接受新的任务,处理等待队列中的任务。
SHUTDOWN:不接受新的任务提交,但是会继续等待队列中的任务
STOP:不接受新的任务提交,不再处理等待队列中的任务,中断正在执行任务的线程
TIDYING:所有的任务都销毁了,workerCount为0,线程池的状态正在转换为TIDYING状态时,会执行钩子方法terminated()。
TERMINATED:上述的terminated()方法结束之后,线程池的状态就会变成这个。

线程池中submit()和execute()方法有什么区别?

  • 相同点:都可以开启线程执行池中的任务
  • 不同点:
    • 接受参数 :execute()只能执行Runnable类型的任务。submit()可以执行Runnable和Callable类型的任务。
    • 返回值:submit()方法可以返回持有计算结果的Future对象,而execute()没有。
    • 异常处理:submit()方便Exception处理

ThreadExecutor饱和策略有哪些?

如果当前同时运行的线程数量达到最大线程数量并且队列也已经放满了,ThreadPoolTaskExecutor定义了一些策略:

  • ThreadPoolTaskExecutor.AbortPolicy:抛出 RejectExecutionException来拒绝新任务的处理。
  • ThreadPoolTaskExecutor.CallerRunsPolicy:调用提交任务的线程运行任务(A线程提交任务,A负责运行)。但是这种策略会降低新任务的提交速度,影响程序的整体性能。如果你的应用程序可以承受此延迟并且你不能丢弃任何一个任务请求的话,你可以选择这个策略。
  • ThreadPoolExecutor.DiscardPolicy:不处理新任务,直接丢弃掉。
  • ThreadPoolExecutor.DiscardOldestPolicy:将丢弃最早的未处理的任务请求。

线程池的执行原理?

在这里插入图片描述
提交一个任务到线程池中,线程池的处理流程如下:

  1. 判断线程池里的核心线程数是否已满,如果不是(核心线程空闲或者还有核心线程没有被创建),则创建一个新的工作线程来执行任务。如果核心线程已满,则进入下个进程。
  2. 线程池判断工作队列是否已满,如果工作队列没有满,则将新提交的任务存储在这个工作队列里。如果工作队列满了,则进入下个流程。
  3. 判断线程池里的线程是否都处于工作状态,如果没有,则创建一个新的工作流程来执行任务。如果已经满了,则交给饱和策略来处理这个任务。

如何合理分配线程池大小?

要合理的分配线程池的大小需要根据实际情况来定,简单来说就是根据CPU密集和IO密集来分配。

  1. CPU密集型时,任务可以少配置线程数,大概和机器的cpu核数相当,这样可以使得每个线程都在执行任务
  2. IO密集型时,大部分线程都阻塞,故需多配置线程数,2*cpu核数
    总结:
  • 线程等待时间比CPU执行时间比例越高,需要越多线程。
  • 线程CPU执行时间比等待时间比例越高,需要越少线程。
    当然,实际应用中没有固定的公式,需要结合测试和监控来进行调整。

线程池如何实现动态修改?

  1. 首先线程池提供了部分setter方法可以设置线程池的参数;
    a. 修改核心线程数,最大线程数,空闲线程停留空间,拒绝策略等。
    b.可以及那个线程池的配置参数放入配置中心,当需要调整的时候,去配置中心修改就行。

  2. 什么时候修改呢?
    a. 这里需要监控报警策略,获取线程池状态指标,当指标判定为异常之后进行报警
    b.分析指标异常原因,评估处理策略,最后通过上述线程提供的接口进行动态修改

使用无界队列的线程池会导致什么问题?

如果线程获取一个任务后,任务的执行时间比较长,会导致队列的任务越积越多,导致机器内存使用不停飙升,最终导致OOM

这篇关于Java线程池和Executor框架-面试与分析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1146502

相关文章

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3

Springboot处理跨域的实现方式(附Demo)

《Springboot处理跨域的实现方式(附Demo)》:本文主要介绍Springboot处理跨域的实现方式(附Demo),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录Springboot处理跨域的方式1. 基本知识2. @CrossOrigin3. 全局跨域设置4.

springboot security使用jwt认证方式

《springbootsecurity使用jwt认证方式》:本文主要介绍springbootsecurity使用jwt认证方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录前言代码示例依赖定义mapper定义用户信息的实体beansecurity相关的类提供登录接口测试提供一

Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

《SpringBoot3.4.3基于SpringWebFlux实现SSE功能(代码示例)》SpringBoot3.4.3结合SpringWebFlux实现SSE功能,为实时数据推送提供... 目录1. SSE 简介1.1 什么是 SSE?1.2 SSE 的优点1.3 适用场景2. Spring WebFlu

基于SpringBoot实现文件秒传功能

《基于SpringBoot实现文件秒传功能》在开发Web应用时,文件上传是一个常见需求,然而,当用户需要上传大文件或相同文件多次时,会造成带宽浪费和服务器存储冗余,此时可以使用文件秒传技术通过识别重复... 目录前言文件秒传原理代码实现1. 创建项目基础结构2. 创建上传存储代码3. 创建Result类4.

Java利用JSONPath操作JSON数据的技术指南

《Java利用JSONPath操作JSON数据的技术指南》JSONPath是一种强大的工具,用于查询和操作JSON数据,类似于SQL的语法,它为处理复杂的JSON数据结构提供了简单且高效... 目录1、简述2、什么是 jsONPath?3、Java 示例3.1 基本查询3.2 过滤查询3.3 递归搜索3.4

Tomcat版本与Java版本的关系及说明

《Tomcat版本与Java版本的关系及说明》:本文主要介绍Tomcat版本与Java版本的关系及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Tomcat版本与Java版本的关系Tomcat历史版本对应的Java版本Tomcat支持哪些版本的pythonJ

springboot security验证码的登录实例

《springbootsecurity验证码的登录实例》:本文主要介绍springbootsecurity验证码的登录实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录前言代码示例引入依赖定义验证码生成器定义获取验证码及认证接口测试获取验证码登录总结前言在spring

SpringBoot日志配置SLF4J和Logback的方法实现

《SpringBoot日志配置SLF4J和Logback的方法实现》日志记录是不可或缺的一部分,本文主要介绍了SpringBoot日志配置SLF4J和Logback的方法实现,文中通过示例代码介绍的非... 目录一、前言二、案例一:初识日志三、案例二:使用Lombok输出日志四、案例三:配置Logback一

springboot security快速使用示例详解

《springbootsecurity快速使用示例详解》:本文主要介绍springbootsecurity快速使用示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录创www.chinasem.cn建spring boot项目生成脚手架配置依赖接口示例代码项目结构启用s