当前位置:首页 > 科技  > 软件

面试官:听说你很懂线程池?

来源: 责编: 时间:2024-04-02 17:17:23 251观看
导读什么是线程池就是一种池化技术,类似的还有jdbc连接池,对象池。所谓线程池,就是提前创建一堆线程,放到内存(池子)中,需要的时候取一个出来用。如上图,最顶层的接口就是Executor,实现ExecutorService接口的类,就是对应的线程池类

什么是线程池

就是一种池化技术,类似的还有jdbc连接池,对象池。所谓线程池,就是提前创建一堆线程,放到内存(池子)中,需要的时候取一个出来用。D6b28资讯网——每日最新资讯28at.com

D6b28资讯网——每日最新资讯28at.com

如上图,最顶层的接口就是Executor,实现ExecutorService接口的类,就是对应的线程池类。D6b28资讯网——每日最新资讯28at.com

如何创建线程池

用Executors工具类,可以很方便地创建各种线程池。(但是实际开发我们不推荐,阿里巴巴的开发手册严令禁止使用Executors,应该用ThreadPoolExecutor)Executors 类可以创建多种类型的线程池,每种线程池都有不同的特点和适用场景。D6b28资讯网——每日最新资讯28at.com

(1) FixedThreadPool(固定大小线程池):D6b28资讯网——每日最新资讯28at.com

  • 使用 Executors.newFixedThreadPool(int nThreads) 方法创建。
  • 具有固定大小的线程池,即线程数量固定不变。
  • 适用于需要控制线程数量的场景,例如服务器端处理请求。

(2) CachedThreadPool(缓存线程池):D6b28资讯网——每日最新资讯28at.com

  • 使用 Executors.newCachedThreadPool() 方法创建。
  • 具有自动调整线程数量的线程池,根据需要创建新线程,空闲线程会被回收。
  • 适用于执行大量短期异步任务的场景,例如异步IO操作。

(3) SingleThreadPool(单线程线程池):D6b28资讯网——每日最新资讯28at.com

  • 使用 Executors.newSingleThreadExecutor() 方法创建。
  • 只有一个工作线程的线程池,所有任务按顺序执行。
  • 适用于需要保证顺序执行的任务场景,例如日志处理。

(4) ScheduledThreadPool(定时任务线程池):D6b28资讯网——每日最新资讯28at.com

  • 使用 Executors.newScheduledThreadPool(int corePoolSize) 方法创建。
  • 具有定时执行任务的功能,可以按固定的频率执行任务。
  • 适用于需要定时执行任务的场景,例如定时任务调度。

(5) WorkStealingPool(工作窃取线程池):D6b28资讯网——每日最新资讯28at.com

  • 使用 Executors.newWorkStealingPool(int parallelism) 方法创建。
  • 基于ForkJoinPool实现的线程池,每个线程都有自己的任务队列,可以窃取其他线程的任务来执行。
  • 适用于需要处理大量并行任务的场景,例如并行计算任务。

为什么不推荐用Executors创建?D6b28资讯网——每日最新资讯28at.com

D6b28资讯网——每日最新资讯28at.com

线程池底层原理

我们以ThreadPoolExecutor为例,它是ExecutorService的一种实现。D6b28资讯网——每日最新资讯28at.com

D6b28资讯网——每日最新资讯28at.com

一般我们根据一个类的构造器,可以看出里面的大致思路:D6b28资讯网——每日最新资讯28at.com

public ThreadPoolExecutor(int corePoolSize,                              int maximumPoolSize,                              long keepAliveTime,                              TimeUnit unit,                              BlockingQueue<Runnable> workQueue,                              ThreadFactory threadFactory,                              RejectedExecutionHandler handler) {        if (corePoolSize < 0 ||            maximumPoolSize <= 0 ||            maximumPoolSize < corePoolSize ||            keepAliveTime < 0)            throw new IllegalArgumentException();        if (workQueue == null || threadFactory == null || handler == null)            throw new NullPointerException();        this.corePoolSize = corePoolSize;        this.maximumPoolSize = maximumPoolSize;        this.workQueue = workQueue;        this.keepAliveTime = unit.toNanos(keepAliveTime);        this.threadFactory = threadFactory;        this.handler = handler;    }

参数很多,但是我们每一个都必须要记住。 这个 ThreadPoolExecutor 的构造函数接受以下参数:一个线程池就好比一家公司,甲方员工干不完需求的时候,就要招一些外包人员驻场开发,如果活干完了,就让外包撤场,只留下自己的员工。D6b28资讯网——每日最新资讯28at.com

  • corePoolSize(核心线程数):线程池中保持活跃的线程数量,即使它们处于空闲状态。当提交任务时,线程池会尝试保持至少这么多数量的线程处于活跃状态。 就是公司正式员工的数量。
  • maximumPoolSize(最大线程数):线程池中允许的最大线程数量。当任务队列已满且核心线程都处于活跃状态时,线程池会创建新的线程,直到达到这个最大线程数。 就是公司甲方员工+外包员工的总数,不能超过这个数量。
  • keepAliveTime(线程空闲时间):非核心线程在空闲状态下的最长存活时间。超过这个时间,多余的非核心线程将被终止,直到线程数量不超过核心线程数。 如果外包员工长时间没需求,就通知乙方撤人,裁掉这个非核心人员。当然,甲方爸爸是不会裁的。
  • unit(时间单位):用于指定 keepAliveTime 参数的时间单位,通常是秒、毫秒、微秒等。
  • workQueue(工作队列):用于保存等待执行的任务的阻塞队列。当所有线程都处于忙碌状态时,新提交的任务会被放入这个队列中等待执行。 当需求多到加上外包员工都做不完了,就只能往后排期了。
  • threadFactory(线程工厂):用于创建新线程的工厂。每个新创建的线程都是通过这个工厂创建的。** 就是定义员工的属性,即工牌,这个员工属于哪个公司的。**
  • handler(拒绝策略):当任务无法被执行时(通常是由于线程池已关闭或者任务队列已满),用于处理被拒绝的任务的策略。常见的拒绝策略包括抛出异常、丢弃任务或者在调用者线程中执行任务。 默认是不处理。

这些参数可以用于配置 ThreadPoolExecutor 对象,以满足不同的线程管理需求。D6b28资讯网——每日最新资讯28at.com

线程池本质就是一个HashSet,所以是无序的。有新的任务提交进来,如果池子还有线程,就直接拿去处理,池子满了就放入阻塞队列,等待有线程空闲。D6b28资讯网——每日最新资讯28at.com

线程数怎么设置比较合理?

这个是没有银弹的,我们一般认为CPU密集型的应用,设置为CPU核数N+1。所谓CPU密集型,就是这个程序计算量比较多,还比较频繁,计算时间长,也就是所谓的比较吃配置,比如是一个专门做算法的服务(组托,配载运算之类的)。 D6b28资讯网——每日最新资讯28at.com

对于IO密集型的应用,设置为2N+1,什么是IO密集型的应用呢,就是提供数据服务比较多,吞吐量比较大,等待时间长的应用,大部分业务系统都属于此类。D6b28资讯网——每日最新资讯28at.com

除此之外,线程数还跟jvm,机器cpu是否可以超线程(云服务器一般没法超线程),我们看到的cpu核数一般不是真实的,所以我们推荐先根据常规设置一个线程数量,上线后根据具体情况再调整就行了。D6b28资讯网——每日最新资讯28at.com

本文链接:http://www.28at.com/showinfo-26-80831-0.html面试官:听说你很懂线程池?

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 千人规模敏捷迭代实践分享,你学会了吗?

下一篇: JSDoc:一个可选的 TypeScript 替代品

标签:
  • 热门焦点
  • K60至尊版刚预热 一加Ace2 Pro正面硬刚

    Redmi这边刚如火如荼的宣传了K60 Ultra的各种技术和硬件配置,作为竞品的一加也坐不住了。一加中国区总裁李杰发布了两条微博,表示在自家的一加Ace2上早就已经采用了和PixelWo
  • 5月iOS设备好评榜:iPhone 14仅排第43?

    来到新的一月,安兔兔的各个榜单又重新汇总了数据,像安卓阵营的榜单都有着比较大的变动,不过iOS由于设备的更新换代并没有那么快,所以相对来说变化并不大,特别是iOS好评榜,老款设
  • 8月总票房已突破10亿!《封神》第一:口碑已经成了

    8月5日消息,据灯塔专业版数据,截至8月5日9时35分,8月总票房(含预售)已突破10亿。其中,《封神》以大比分的优势领先。根据官方消息,目前该片总票房已经超过14.
  • 线程通讯的三种方法!通俗易懂

    线程通信是指多个线程之间通过某种机制进行协调和交互,例如,线程等待和通知机制就是线程通讯的主要手段之一。 在 Java 中,线程等待和通知的实现手段有以下几种方式:Object 类下
  • 共享单车的故事讲到哪了?

    来源丨海克财经与共享充电宝相差不多,共享单车已很久没有被国内热点新闻关照到了。除了一再涨价和用户直呼用不起了。近日多家媒体再发报道称,成都、天津、郑州等地多个共享单
  • 阿里瓴羊One推出背后,零售企业迎数字化新解

    作者:刘旷近年来随着数字经济的高速发展,各式各样的SaaS应用服务更是层出不穷,但本质上SaaS大多局限于单一业务流层面,对用户核心关切的增长问题等则没有提供更好的解法。在Saa
  • 造车两年股价跌六成,小米的估值逻辑变了吗?

    如果从小米官宣造车后的首个交易日起持有小米集团的股票,那么截至2023年上半年最后一个交易日,投资者将浮亏59.16%,同区间的恒生科技指数跌幅为52.78%
  • 上海举办人工智能大会活动,建设人工智能新高地

    人工智能大会在上海浦江两岸隆重拉开帷幕,人工智能新技术、新产品、新应用、新理念集中亮相。8月30日晚,作为大会的特色活动之一的上海人工智能发展盛典人工
  • 世界人工智能大会国际日开幕式活动在世博展览馆开启

    30日上午,世界人工智能大会国际日开幕式活动在世博展览馆开启,聚集国际城市代表、重量级院士专家、国际创新企业代表,共同打造人工智能交流平台。上海市副市
Top