线程池的创建方式

线程池创建一般两种:第一种是:调用Executors中的静态工厂方法之一来创建一个线程池 ;第二种:通过ThreadPoolExecutor类来创建。

线程池创建一般两种:

第一种是:调用Executors中的静态工厂方法之一来创建一个线程池 

  • newFixedThreadPool:将创建一个固定长度的线程池,每当提交一个任务时就创建一个线程,直到达到线程池的最大数量,这时线程池的规模将不再变化(如果某个线程由于发生了未预期的Exception而结束,那么线程池会补充一个新的线程)。
  • newCachedThreadPool:将创建一个可缓存的线程池,如果线程池的当前规模超过了处理需求时,那么将回收空闲的线程,而当需求增加时,则可以添加新的线程,线程池的规模不存在任何限制。 
  • newSingleThreadExecutor:是一个单线程的Executor,它创建单个工作者线程来执行任务,如果这个线程异常结束,会创建另一个线程来替代。newSingleThreadExecutor能确保依照任务在队列中的顺序来串行执行(例如FIFO、LIFO、优先级)。
  • newScheduledThreadPool:创建了一个固定长度的线程池,而且以延迟或定时的方式来执行任务

attachments-2020-11-OyPhJYpA5fb6385d3d648.png 但是《阿里巴巴Java开发手册》建议不采用Executors创建线程池,也是让写的同学更加明确线程池的运行规则,规避资源耗尽的风险,其实Executors类创建线程池的时候实际就是调用ThreadPoolExecutor类的构造方法来创建。

第二种:通过ThreadPoolExecutor类来创建

new  ThreadPoolExecutor(int corePoolSize,
        int maximumPoolSize,
        long keepAliveTime,
        TimeUnit unit,
        BlockingQueue<Runnable> workQueue,
        ThreadFactory threadFactory,
        RejectedExecutionHandler handler) 

corePoolSize(线程池的基本大小):当提交一个任务到线程池时,线程池会创建一个线程来执行任务,即使其他空闲的基本线程能够执行新任务也会创建线程,等到需要执行的任务数大于线程池基本大小时就不再创建。如果调用了线程池的prestartAllCoreThreads()方法, 线程池会提前创建并启动所有基本线程。

maximumPoolSize(线程池最大数量):线程池允许创建的最大线程数。如果队列满了,并 且已创建的线程数小于最大线程数,则线程池会再创建新的线程执行任务。值得注意的是,如 果使用了无界的任务队列这个参数就没什么效果。

keepAliveTime(线程活动保持时间):线程池的工作线程空闲后,保持存活的时间。所以, 如果任务很多,并且每个任务执行的时间比较短,可以调大时间,提高线程的利用率。

TimeUnit(线程活动保持时间的单位):可选的单位有天(DAYS)、小时(HOURS)等等。

workQueue(任务队列):用于保存等待执行的任务的阻塞队列。可以选择以下几个阻塞队列。 

  • ArrayBlockingQueue:是一个基于数组结构的有界阻塞队列,此队列按FIFO(先进先出)原 则对元素进行排序。 
  • LinkedBlockingQueue:一个基于链表结构的阻塞队列,此队列按FIFO排序元素,吞吐量通 常要高于ArrayBlockingQueue。静态工厂方法Executors.newFixedThreadPool()使用了这个队列。 
  • SynchronousQueue:一个不存储元素的阻塞队列。每个插入操作必须等到另一个线程调用 移除操作,否则插入操作一直处于阻塞状态,吞吐量通常要高于Linked-BlockingQueue,静态工 厂方法Executors.newCachedThreadPool使用了这个队列。
  • PriorityBlockingQueue:一个具有优先级的无限阻塞队列。

ThreadFactory:用于设置创建线程的工厂,可以通过线程工厂给每个创建出来的线程设 置更有意义的名字。

RejectedExecutionHandler(饱和策略):当队列和线程池都满了,说明线程池处于饱和状 态,那么必须采取一种策略处理提交的新任务。这个策略默认情况下是AbortPolicy,表示无法 处理新任务时抛出异常。可以实现RejectedExecutionHandler接口自定义策略

  • AbortPolicy:默认的饱和策略,该策略将抛出未检查的RejectedExecution-Exception。调用者可以捕获这个异常,然后根据需求编写自己的处理代码。
  • CallerRunsPolicy:实现了一种调节机制,该策略既不会抛弃任务,也不会抛出异常。它不会在线程池的某个线程中执行新提交的任务,而是在一个调用了execute的主线程中执行该任务。
  • DiscardOldestPolicy:会抛弃下一个将被执行的任务,然后尝试重新提交新的任务。(如果工作队列是一个优先队列,那么“抛弃最旧的”策略将导致抛弃优先级最高的任务,因此最好不要将“抛弃最旧的”饱和策略和优先级队列放在一起使用。
  • DiscardPolicy:不处理,丢弃掉。attachments-2020-11-YYXnIEdt5fb6381524377.png


  • 发表于 2020-11-19 17:19
  • 阅读 ( 22 )

0 条评论

请先 登录 后评论
热爱技术的小仓鼠
热爱技术的小仓鼠

145 篇文章

作家榜 »

  1. NX小编 1233 文章
  2. 58沈剑 311 文章
  3. 热爱技术的小仓鼠 145 文章
  4. 奈学教育 139 文章
  5. 李希沅 | 奈学教育 41 文章
  6. 江帅帅 | 奈学教育 29 文章
  7. 林淮川 | 奈学教育 12 文章
  8. 邱鹏超 3 文章