线程池中的常见面试题

目录

1. 线程池相比于线程有什么优点

2. 线程池的参数有哪些

3. 线程工厂有什么用

4. 说一下线程的优先级

5. 说一下线程池的执行流程

6. 线程池的拒绝策略有哪些

7. 如何实现自定义拒绝策略

8. 如何判断线程池中的任务是否执行完成

1. 线程池相比于线程有什么优点

有时候面试官也会这么问 ： 让你介绍一下线程池，都是一样的回答方式。

在实际生活中，一般都是使用线程池，而不使用普通的线程，使用线程池有以下几个好处：

1. 降低资源消耗：线程池可以重复利用已经创建好的线程，避免了频繁创建和销毁线程带来的开销。其次呢，线程池可以有效地管理和控制线程的数量，避免线程过多而导致资源浪费。

2. 提高响应速度：线程池中的线程是预先创建好的，所以当任务来临时，它可以立即分配线程来进行处理，提高了任务的响应速度。

3. 提高系统稳定性：线程池可以限制并发时的线程数量，避免因为线程过多而导致资源耗尽或系统崩溃。它可以合理的控制系统的负载，以提高系统的稳定性。

4. 支持任务队列：线程池通常会使用任务队列来存储待执行的任务。当线程池中的线程都在执行任务时，新的任务可以被放入任务队列中排队等待执行，避免任务丢失或阻塞。

2. 线程池的参数有哪些

线程池 ThreadPoolExecutor 最多可以支持 7 个参数的设置（最少 5 个），底层源码：

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler) {
    if (corePoolSize < 0 ||
        // maximumPoolSize 必须大于 0, 且必须大于 corePoolSize 
        maximumPoolSize <= 0 ||
        maximumPoolSize < corePoolSize ||
        keepAliveTime < 0)
        throw new IllegalArgumentException();
    if (workQueue == null || threadFactory == null || handler == null)
        throw new NullPointerException();
    this.acc = System.getSecurityManager() == null ?
            null :
            AccessController.getContext();
    this.corePoolSize = corePoolSize;
    this.maximumPoolSize = maximumPoolSize;
    this.workQueue = workQueue;
    this.keepAliveTime = unit.toNanos(keepAliveTime);
    this.threadFactory = threadFactory;
    this.handler = handler;
}

7 个参数的含义如下 :

1. corePoolSize：表示线程池的常驻核心线程数

        这个值如果设为 0， 则表示在没有任务的时候，销毁线程池；如果大于 0，即使没有任务也会保证线程池的线程数量等于这个值。（这个值如果设置的比较小，则会频繁的创建和销毁线程；如果设置的比较大，则浪费系统资源，实际工作中根据业务场景来调整）

2. maximumPoolSize：表示线程池在任务最多的时候，最大可以创建的线程数

        官方规定这个值必须大于 0。也必须大于等于 corePoolSize，（此值只有在任务比较多的时候，且任务队列已经存满的时候，才会用到）

3. keepAliveTime：表示临时线程（最大线程数-核心线程数）的存活时间

        当线程池空闲时并且超过了这个时间，就会销毁临时线程，直到线程池中的线程数量等于 corePoolSize 为止。

4. unit：表示临时线程的存活单位

5. workQueue：表示线程池执行的任务队列

        当线程池的所有线程都在处理任务时，新加入的任务就会缓存到任务队列中，排队等待执行。

6.threadFactory：表示线程的创建工厂

        可以用来设置线程名称，线程优先级，以及线程的类型（前后台线程）等内容。

7. RejectedExecutionHandler：表示指定线程池的拒绝策略

        当线程池中的核心线程数都在执行任务，任务队列此也已经满了，并且线程池中的线程数已经达到设置的最大线程数了（不能创建新线程了），就会使用到拒绝策略，它是一种限流保护的机制。

3. 线程工厂有什么用

通过线程工厂可以设置线程池中可以创建的最大线程数，设置线程的名称，线程的优先级以及线程的类型等内容。

ThreadFactory threadFactory = new ThreadFactory() {
    @Override
    public Thread newThread(Runnable r) {
        // 创建线程池中的线程
        Thread thread = new Thread(r);
        // 设置线程名称
        thread.setName("Thread-" + r.hashCode());
        // 设置线程的优先级 (1-10) 最大 10
        thread.setPriority(Thread.MAX_PRIORITY);
        // 设置线程的类型 (前台/后台线程)
        thread.setDaemon(false);
        // ....
        return thread;
    }
};

4. 说一下线程的优先级

线程的优先级用整数表示，范围在 1-10 之间，并且数字越大表示的优先级越高，线程的默认优先级为 5。

设置线程优先级的作用：

        线程优先级表示当前线程被调度的权重，也就是说线程的优先级越高，表示线程被被调度执行的可能性就越大，它会给线程调度器一个建议，具体是不是优先级越高的越先执行是不一定的。它这样设计的目的就是为了防止线程饿死。

在 Java 中，可以通过 Thread 类的 setPriority() 和 个体 getPriority()  来设置和获取线程的优先级

5. 说一下线程池的执行流程

线程池的执行流程通过下图进行梳理：

由于线程池是以懒加载的方式进行创建线程的，所以线程池创建第一个线程的时候，它普通的创建线程没有区别。

  1. 当任务来临时，它会先去判断一下实际线程数是否大于核心线程数，如果小于等于核心线程数，说明此时任务比较少，所以此时只需要创建一个新的线程来执行任务就完事了。
  2. 如果实际线程数大于核心线程数了，然后再去判断任务队列有没有满，如果队列没有满，那么就将新任务加入到任务队列中排队等待执行。
  3. 如果队列满了，那么再去判断实际线程数是否超过最大线程数，如果没有超过，那么创建一个新的线程来执行任务就完事了。
  4. 如果已经超过最大线程数了，那么就会执行拒绝策略。

【联系到快递公司】

  1. 当有新的快递来临了，我先看一下公司正式员工忙不忙的过来，如果有人空闲，那么安排空闲的人去干活。
  2. 如果公司的正式员工手头都忙不过来，此时检查一下快递仓库是否满了，如果没满，那么就放入快递仓库排队等待执行。
  3. 如果快递仓库也满了，老板此时还想挣这个钱，那么他会先计算出当前要招多少员工，才能保证利益最大化，如果当前公司总员工（正式+临时）还没有超过预算值，那么就招临时工来帮忙。
  4. 如果说招的临时工已经达到最大预算了，那么此时就会执行拒绝策略了，我不接单了。

6. 线程池的拒绝策略有哪些

拒绝策略一共有 5 种，线程池内置了 4 种和一种自定义拒绝策略，这四种拒绝策略分别是 ：

1. AbortPolicy：终止策略，线程池会抛出异常并终止执行此任务；

        在接不了订单的情况下，公司还有部门接单，那么领导就会开内部批斗大会，并终止快递流程。

2. CallerRunsPolciy：把任务交给添加此任务的（main）线程来执行；

        在接不了订单的情况下，此时有一个卡车司机拉了一车快递来了，于是跟货车司机说：老弟啊，哥这也忙不过来了，你想不想挣个块钱发家致富，于是就将这个任务交给卡车司机来执行。

3. DiscardPolicy：忽略当前任务（最新的任务）；

4. DiscardOldestPolicy：忽略任务队列中最早加入的任务，接收新任务（加入任务队列）；

线程池默认的拒绝策略为 AbortPolicy 终止策略。

7. 如何实现自定义拒绝策略

代码示例：

// 创建 runnable 对象
// ...

ThreadPoolExecutor threadPool =
   new ThreadPoolExecutor(1, 1,
   100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
   new RejectedExecutionHandler() {
       @Override
       public void rejectedExecution(Runnable r,ThreadPoolExecutor executor) {
           // 执行自定义拒绝策略
           // 1.记录日志,方便问题的追溯
           // 2.通知相关人员来解决问题
           System.out.println("执行自定义拒绝策略");
       }
   });
// 添加并执行 3 个任务
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);

拒绝策略里面一般可以做两件事：

  1. 记录日志，以便问题的追溯；
  2. 通过相关人员来解决问题。

如果面试官此时还问：你在实际工作中/你的项目中，你使用的是哪一种拒绝策略？

        如果不知道怎么回答，建议回答自定义拒绝策略，因为它比较灵活，它可以去设置我想去设置的一些代码，我在里面呢，首先我可以把错误记录下来，其次我可以给任务队列发一个邮件，或者发一个 MQ（消息不丢失）

8. 如何判断线程池中的任务是否执行完成

        " 牛客上有人在面试用友的时候，被问到王者荣耀 5 个人都加载完成才进入游戏，用 Java 应该怎么实现，就和这个问题如出一辙 "

判断线程池中的任务是否执行完成，有三种方法：（线程池提供了两种，还可以借助计数器）

1. 使用 getCompletedTaskCount() 统计已经执行完的任务，使用 getTaskCount() 获取线程池的总任务，将二者进行对比，如果相等就说明线程池的任务执行完了，反之没有执行完。

2. 使用 FutureTask 等待所有任务执行完。（类似于 Thread 里面的 join）

3. 借助计数器 CountDownLatch 或 CyclicBarrier 来实现。

① getCompletedTaskCount() 方式

private static void isCompleteByTaskCount(ThreadPoolExecutor threadPool) {
    while(threadPool.getCompletedTaskCount()
            != threadPool.getTaskCount()) {
        // 如果 已完成任务数 ！= 总任务数, 就一直进行自旋
    }
}

这种方式的缺点：

  1. 如果已完成任务数 != 总任务数，那么就会一直自旋，过于消耗系统性能；
  2. 判断不够精准，因为线程池是公用的，如果这个时候有其他线程来添加了新的任务，那么总的任务数就变了，而我只想判断属于我的这几个任务知否执行完。

所以 getCompletedTaskCount() 并不是最优的实现方式。

② FutureTask 的方式

代码示例：

  1. 定义三个任务 （callable）
  2. 调用线程池提供的 submit 方法 （可执行回调任务/非回调任务）
  3. 调用任务的 get() 方法 （同步阻塞，类似于 thread.join()）
public static void main(String[] args) throws ExecutionException,
             InterruptedException {
    // 创建固定大小的线程池
    ExecutorService executor = Executors.newFixedThreadPool(3);
    // 创建 3 个任务
    FutureTask<Integer> task1 = new FutureTask<>(() -> {
        System.out.println("task1 开始执行");
        Thread.sleep(2000);
        System.out.println("task1 执行结束");
        return 1;
    });
    FutureTask<Integer> task2 = new FutureTask<>(() -> {
        System.out.println("task2 开始执行");
        Thread.sleep(2000);
        System.out.println("task2 执行结束");
        return 2;
    });
    FutureTask<Integer> task3 = new FutureTask<>(() -> {
        System.out.println("task3 开始执行");
        Thread.sleep(2000);
        System.out.println("task3 执行结束");
        return 3;
    });
    // 提交 3 个任务给线程池
    executor.submit(task1);
    executor.submit(task2);
    executor.submit(task3);
    // 等所有任务执行完毕并获取结果 (同步阻塞)
    int ret1 = task1.get();
    int ret2 = task1.get();
    int ret3 = task1.get();
}

执行结果 >>>

③ 使用 CountDownLatch 或 CyclicBarrier

这个问题，回答前两种方式其实已经够了，此处多介绍一个 CountDownLatch。

代码示例：

  1. 递归枚举出所有 HTML 文件
  2. 通过线程池解析 HTML 文件
  3. 解析完所有的 HTML 文件后再执行后续的业务逻辑
public void runByThread() throws InterruptedException {
    ArrayList<File> files = new ArrayList<>();
    enumFile(INPUT_PATH,files); // 递归枚举出所有 HTML 文件
    ExecutorService executorService = Executors.newFixedThreadPool(4);
    CountDownLatch latch = new CountDownLatch(files.size());
    // 遍历文件,多线程解析文件
    for(File f:files) {
        executorService.submit(new Runnable() {
            @Override
            public void run() {
                System.out.println("开始解析: " + f.getAbsolutePath());
                parseHTML(f); // 解析文件
                latch.countDown(); // 调用一次这个方法表示一个线程已经执行完了
            }
        });
    }
    latch.await(); // 阻塞(死等) -> 直到所有的线程都调用了 countDown()
    // 执行后续的业务逻辑
    System.out.println("索引制作完毕!");
}

那么上述三个步骤，4 个线程在执行解析文件的时候，很可能会存在这样一种情况：

这些文件都 submit 完了，但是还没有执行完，这是很有可能的。而想要执行后续的业务逻辑，那么就得保证这些文件全部被执行完了，所以此处 CountDownLatch 的作用就是为了保证这一点的

如何保证？ 通过调用两个方法 ：

  1. latch.await()
  2. latch.countDown()

第一个方法的作用是阻塞，它会一直进行死等，直到所有的线程都执行完了（全部都调用了 countDown() 方法），才结束阻塞。

第二个方法的作用是用来统计线程的执行情况，有一个线程执行完了，计数器就 - 1，直到计数器为 0 的时候，就可以结束 await() 方法的阻塞了。

【区别】

        CountDownLatch 和 CyclicBarrier 的最大的区别就在于 CountDownLatch 是一次性的计数器，而 CyclicBarrier 是可以重复使用的计数器，CyclicBarrier 它的内部是有一个回调方法的 （runnable 的 run 方法）。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/78960.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Rancher管理K8S

Rancher管理K8S

1 介绍 Rancher是一个开源的企业级多集群Kubernetes管理平台&#xff0c;实现了Kubernetes集群在混合云本地数据中心的集中部署与管理&#xff0c;以确保集群的安全性&#xff0c;加速企业数字化转型。Rancher 1.0版本在2016年就已发布&#xff0c;时至今日&#xff0c;Ranche…
阅读更多...
【宝藏应用】AI绘图网站

【宝藏应用】AI绘图网站

序言 这是一个通过AI模型进行绘制图片的网站。 有图有真相 这些是我在上面找的AI生成的图片&#xff0c;感觉怎么样呢&#xff1f;是不是看起来接近真人的精修图片了&#xff1f; 地址 链接: LiblibAI
阅读更多...
sql中union all、union、intersect、minus的区别图解，测试

sql中union all、union、intersect、minus的区别图解，测试

相关文章 sql 的 join、left join、full join的区别图解总结&#xff0c;测试&#xff0c;注意事项 1.结论示意图 对于intersect、minus&#xff0c;oracle支持&#xff0c;mysql不支持&#xff0c;可以变通&#xff08;in或exists&#xff09;实现 2.创建表和数据 -- 建表…
阅读更多...
GPT垂直领域相关模型 现有的开源领域大模型

GPT垂直领域相关模型 现有的开源领域大模型

对于ToC端来说&#xff0c;广大群众的口味已经被ChatGPT给养叼了&#xff0c;市场基本上被ChatGPT吃的干干净净。虽然国内大厂在紧追不舍&#xff0c;但目前绝大多数都还在实行内测机制&#xff0c;大概率是不会广泛开放的&#xff08;毕竟&#xff0c;各大厂还是主盯ToB、ToG市…
阅读更多...
FPGA芯片IO口上下拉电阻的使用

FPGA芯片IO口上下拉电阻的使用

FPGA芯片IO口上下拉电阻的使用 为什么要设置上下拉电阻一、如何设置下拉电阻二、如何设置上拉电阻为什么要设置上下拉电阻 这里以高云FPGA的GW1N-UV2QN48C6/I5来举例，这个芯片的上电默认初始化阶段，引脚是弱上来模式，且模式固定不能通过软件的配置来改变。如下图所示： 上…
阅读更多...
Git 删除 GitHub仓库的文件

Git 删除 GitHub仓库的文件

新建文件夹 git bash here 在新建的文件夹里右键git bash here打开终端&#xff0c;并执行git init初始化仓库 git clone <你的地址> 找到github上要删除的仓库地址&#xff0c;并复制&#xff0c;在终端里输入git clone <你的地址> 要删除文件的库里右键git b…
阅读更多...
对象存储服务-MinIO基本集成

对象存储服务-MinIO基本集成

是什么 MinIO 是一个高性能的分布式对象存储服务&#xff0c;适合存储非结构化数据&#xff0c;如图片&#xff0c;音频&#xff0c;视频&#xff0c;日志等。对象文件最大可以达到5TB。 安装启动 mkdir -p /usr/local/minio cd /usr/local/minio# 下载安装包 wget https:/…
阅读更多...
从0到1：通用后台管理系统 echarts图使用及其参数

从0到1：通用后台管理系统 echarts图使用及其参数

这一章主要讲在系统概览模块中&#xff0c;所使用的echarts图及其参数 echarts是一个基于 JavaScript 的开源可视化图表库&#xff0c; 官网直通车 是在各种后台管理系统的开发中都常见的一种库&#xff0c;也是前端开发管理系统所必学的一种库 那么在项目中主要是使用了饼…
阅读更多...
Unity实现异步加载场景

Unity实现异步加载场景

一&#xff1a;创建UGUI 首先我们在LoginCanvas登入面板下面创建一个Panel,取名为LoadScreen,再在loadScreen下面创建一个Image组件&#xff0c;放置背景图片&#xff0c;然后我们再在lpadScreen下面继续创建一个Slider,这个是用来加载进度条的&#xff0c;我们改名为LoadSlid…
阅读更多...
Elasticsearch的一些基本概念

Elasticsearch的一些基本概念

文章目录 基本概念&#xff1a;文档和索引JSON文档元数据索引REST API 节点和集群节点Master eligible节点和Master节点Data Node 和 Coordinating Node其它节点 分片(Primary Shard & Replica Shard)分片的设定操作命令 基本概念&#xff1a;文档和索引 Elasticsearch是面…
阅读更多...
顺序表（数据结构）

顺序表（数据结构）

“路虽远&#xff0c;行则将至” ❤️主页&#xff1a;小赛毛 顺序表目录 1.线性表 2.顺序表 概念及结构 静态顺序表&#xff1a;使用定长数组存储元素。 动态顺序表&#xff1a;使用动态开辟的数组存储。 接口实现 1.线性表 线性表 &#xff08; linear list &#xff09; 是…
阅读更多...
idea如何建立web项目？？？

idea如何建立web项目？？？

我们需要用到tomcat&#xff0c;没有下在着小伙伴&#xff0c;可以借鉴这篇博客&#xff1a; 如何正确下载tomcat&#xff1f;&#xff1f;&#xff1f;_明天更新的博客-CSDN博客 1.建立普通的Java项目。 2.简单编写index.jsp文件 3.添加tomcat 4.运行服务器 5.构建Servlet 最后…
阅读更多...
突破瓶颈，提升学习效率的考试培训系统

突破瓶颈，提升学习效率的考试培训系统

在现代社会中&#xff0c;教育和培训已经成为人们提升自我能力的重要途径。尤其在考试备考过程中&#xff0c;学习效率的提升显得尤为重要。为了帮助学习者突破学习瓶颈&#xff0c;提高学习效果&#xff0c;我们开发了一款全新的考试培训系统。 我们的系统为学习者提供了全方…
阅读更多...
SpringBoot复习：（52）不再需要使用@EnableTransactionManagement的原因

SpringBoot复习：（52）不再需要使用@EnableTransactionManagement的原因

在Spring项目中&#xff0c;要用事务&#xff0c;需要EnableTransactionManagement注解加Transactional注解。而在SpringBoot项目&#xff0c;有事务的自动配置类TransactionAutoConfiguration,代码如下&#xff1a; 可以在其内部类EnableTransactionManagementConfiguratio…
阅读更多...
651页23万字智慧教育大数据信息化顶层设计及建设方案WORD

651页23万字智慧教育大数据信息化顶层设计及建设方案WORD

导读&#xff1a;原文《651页23万字智慧教育大数据信息化顶层设计及建设方案WORD》&#xff08;获取来源见文尾&#xff09;&#xff0c;本文精选其中精华及架构部分&#xff0c;逻辑清晰、内容完整&#xff0c;为快速形成售前方案提供参考。 目录 一、 方案背景 1.1 以教育…
阅读更多...
电动汽车太秀了！用一个技巧搞定了蓄电池！

电动汽车太秀了！用一个技巧搞定了蓄电池！

当涉及能源存储和供应&#xff0c;特别是在太阳能、电动车和不间断电源等领域&#xff0c;蓄电池无疑是关键的组成部分。然而&#xff0c;蓄电池的状态、性能和健康状况对于系统的可靠性和效率至关重要。 蓄电池监控通过实时监测、数据分析和预警功能&#xff0c;它提供了更高效…
阅读更多...
React 全栈体系（二）

React 全栈体系（二）

第二章 React面向组件编程 一、基本理解和使用 1. 使用React开发者工具调试 2. 效果 2.1 函数式组件 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>1_函数式组件</title> </head> &l…
阅读更多...
Docker、Linux网络代理设置

Docker、Linux网络代理设置

网络代理 linux机器通过windows主机代理访问外网 windows机器借用 CCProxy 软件&#xff0c;官网下载免费版(http://www.ccproxy.com/) CCProxy 默认使用808端口&#xff0c;如果端口冲突可以在设置处修改 在帐号处添加允许的linux机器ip&#xff0c;也可以直接允许所有ip,其…
阅读更多...
JVM——类文件结构

JVM——类文件结构

文章目录 一 概述二 Class 文件结构总结2.1 魔数2.2 Class 文件版本2.3 常量池2.4 访问标志2.5 当前类索引,父类索引与接口索引集合2.6 字段表集合2.7 方法表集合2.8 属性表集合 一 概述 在 Java 中&#xff0c;JVM 可以理解的代码就叫做字节码&#xff08;即扩展名为 .class …
阅读更多...
K8S系列二：实战入门

K8S系列二：实战入门

写在前面 本文是K8S系列第二篇&#xff0c;主要面向对K8S新手同学&#xff0c;阅读本文需要读者对K8S的基本概念&#xff0c;比如Pod、Deployment、Service、Namespace等基础概念有所了解。尚且不熟悉的同学推荐先阅读本系列的第一篇文章&#xff1a;《K8S系列一&#xff1a;概…
阅读更多...
最新文章

Copyright @ 2022~2023