ThreadPoolExecutor类分析
  Olt1rl96HKat 2023年11月05日 57 0

ThreadPoolExecutor类中提供的构造方法。

/**
 * ⽤给定的初始参数创建⼀个新的ThreadPoolExecutor。
 */
 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;
 }

corePoolSize:核心线程数,定义了最小可以同时运行的线程数量。

maximumPoolSize:当队列中存放的任务达到队列容量的时候,当前可以同时运行的线程数量变为最大线程数。

workQueue:当新任务来的时候会先判断当前运行的线程数量是否达到核心线程数,如果达到的话,新任务就会存放到队列中。

keepAliveTime:当线程池中的线程数量大于corePoolSize的时候,如果这时没有新的任务提交,核心线程外的线程不会立即销毁,而是会等待,直到等待的时间超过了keepAliveTime才会被回收销毁。

unit:keepAliveTime参数的时间单位。

threadFactory:executor创建新线程的时候会用到。

handler:饱和策略。

ThreadPoolExecutor饱和策略

如果当前用时运行的线程数量达到最大线程数量并且队列也已经被放满了任务时,ThreadPoolExecutor定义了一些策略。

ThreadPoolExecutor.AbortPolicy:抛出RejectedExecutionException来拒绝新任务的处理。

ThreadPoolExecutor.CallRunsPolicy:调用执行自己的线程运行任务。但是这种策略会降低对新任务提交速度,影响程序的整体性能。另外,这个策略喜欢增加队列容量。如果应用程序可以承受此延迟并且不能丢弃任何一个任务请求的时候,可以选择这个策略。

ThreadPoolExecutor.DiscardPolicy:不处理新任务,直接丢弃掉。

ThreadPoolExecutor.DiscardOldestPolicy:此策略将丢弃最早的未处理的任务请求。

【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

上一篇: 运行时常量池 下一篇: 上下文切换
  1. 分享:
最后一次编辑于 2023年11月08日 0

暂无评论

Olt1rl96HKat
作者其他文章 更多

2023-12-22

2023-12-22

2023-12-15

2023-12-15

2023-12-15

2023-12-15

2023-12-15