• 线程池自义定参数设置及预估


    一、ThreadPoolExecutor类可设置的参数主要有:

    1.1 corePoolSize:核心线程

    a.核心线程会一直存活,及时没有任务需要执行
    b.当线程数小于核心线程数时,即使有线程空闲,线程池也会优先创建新线程处理
    c.设置allowCoreThreadTimeout=true(默认false)时,核心线程会超时关

    1.2 queueCapacity:任务队列容量(阻塞队列)

    当核心线程数达到最大时,新任务会放在队列中排队等待执行

    1.3 maxPoolSize:最大线程数

    a.当线程数>=corePoolSize,且任务队列已满时。线程池会创建新线程来处理任务
    b.当线程数=maxPoolSize,且任务队列已满时,线程池会拒绝处理任务而抛出异常

    1.4 keepAliveTime:线程空闲时间

    a.当线程空闲时间达到keepAliveTime时,线程会退出,直到线程数量=corePoolSize
    b.如果allowCoreThreadTimeout=true,则会直到线程数量=0

    1.5 rejectedExecutionHandler:任务拒绝处理器

    两种情况会拒绝处理任务:
    a.当线程数已经达到maxPoolSize,切队列已满,会拒绝新任务
    b.当线程池被调用shutdown()后,会等待线程池里的任务执行完毕,再shutdown。如果在调用shutdown()和线程池真正shutdown之间提交任务,会拒绝新任务。

    线程池会调用rejectedExecutionHandler来处理这个任务。如果没有设置,默认是AbortPolicy,会抛出异常。
    ThreadPoolExecutor类有几个内部实现类来处理拒绝任务:
    a.AbortPolicy 丢弃任务,抛运行时异常
    b.CallerRunsPolicy 执行任务
    c.DiscardPolicy 忽视,什么都不会发生
    d.DiscardOldestPolicy 从队列中踢出最先进入队列(最后一个执行)的任务
    e.实现RejectedExecutionHandler接口,可自定义处理器

    二、任务异常处理

    默认情况:线程池执行器抛出了异常 如果线程池执行器(Executor)抛出了异常,那么这个线程池的所有线程都会中止运行

    线程池中任务异常方法:

    1.run()方法捕捉处理

    2.通过FutureTask的get()方法捕捉处理异常

    三、参数预估

    3.1 corePoolSize 核心线程

    按任务类型分配,如果是cpu密集型则(核数+1),如果是IO密集型则(核数*2)或(核数*2+1)

    3.2 queueCapacity:任务队列的长度

    任务队列的长度=核心线程数/任务处理时间。

    例如:

    核实线程数是5,任务执行时间0.1s,任务队列长度=5/0.1=50。

    总结:预估参数可以作为初始设定,最终还需根据实际情况(内存,cpu处理能力)设定

    注:如有问题,欢迎指正

  • 相关阅读:
    C++模板初阶
    怎么调监控清晰度,监控画面不清晰怎么修复?
    鬼笔环肽(异硫氰酸荧光素标记)
    【中秋国庆不断更】OpenHarmony多态样式stateStyles使用场景
    大模型的魔法
    wpfui:一个开源免费具有现代化设计趋势的WPF控件库
    帆软报表中sql的模糊查询的用法
    web-view 调用微信小程序的方法
    【100个 Unity实用技能】☀️ | UGUI Text中加入超链接文本,可直接点击跳转
    Less混合结合:nth-child()选择器的高级玩法
  • 原文地址:https://blog.csdn.net/ShaoFuQiJie/article/details/133870997