java提供的线程池

小知识,大挑战!本文正在参与“  程序员必备小知识  ”创作活动

本文同时参与 「掘力星计划」  ,赢取创作大礼包,挑战创作激励金

java提供的线程池

Java中默认实现好的线程池又有哪些呢?今天就给大家分享一下Java中默认实现了的线程池,废话不多说,我们就一起直接看一下吧。

SingleThreadExecutor线程池

SingleThreadExecutor线程池 这个线程池只有一个核心线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。

参数:

  • corePoolSize:1,只有一个核心线程在工作。
  • maximumPoolSize:1。
  • keepAliveTime:0L。
  • workQueue:newLinkedBlockingQueue<Runnable>(),其缓冲队列是无界的。

FixedThreadPool线程池

FixedThreadPool线程池是固定大小的线程池,只有核心线程。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。

FixedThreadPool多数针对一些很稳定很固定的正规并发线程,多用于服务器。

参数:

  • corePoolSize:nThreads
  • maximumPoolSize:nThreads
  • keepAliveTime:0L
  • workQueue:newLinkedBlockingQueue<Runnable>(),其缓冲队列是无界的。

CachedThreadPool线程池

CachedThreadPool是无界线程池,如果线程池的大小超过了处理任务所需要的线程,那么就会回收部分空闲(60秒不执行任务)线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。

线程池大小完全依赖于操作系统(或者说JVM)能够创建的最大线程大小。SynchronousQueue是一个是缓冲区为1的阻塞队列。 缓存型池子通常用于执行一些生存期很短的异步型任务,因此在一些面向连接的daemon型SERVER中用得不多。但对于生存期短的异步任务,它是Executor的首选。

参数:

  • corePoolSize:0
  • maximumPoolSize:Integer.MAX_VALUE
  • keepAliveTime:60L
  • workQueue:newSynchronousQueue(),一个是缓冲区为1的阻塞队列。

ScheduledThreadPool线程池

ScheduledThreadPool:核心线程池固定,大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。创建一个周期性执行任务的线程池。如果闲置,非核心线程池会在DEFAULT_KEEPALIVEMILLIS时间内回收。

参数:

  • corePoolSize:corePoolSize
  • maximumPoolSize:Integer.MAX_VALUE
  • keepAliveTime:DEFAULT_KEEPALIVE_MILLIS
  • workQueue:newDelayedWorkQueue()

那么怎么往线程池中提交任务呢?

线程池最常用的提交任务的方法有两种:

  1. execute():ExecutorService.execute方法接收一个Runable实例,它用来执行一个任务:

  2. submit():ExecutorService.submit()方法返回的是Future对象。可以用isDone()来查询Future是否已经完成,当任务完成时,它具有一个结果,可以调用get()来获取结果。也可以不用isDone()进行检查就直接调用get(),在这种情况下,get()将阻塞,直至结果准备就绪。

好了,这就是java中提供的线程池,我们需要了解其中的参数信息,然后灵活运用它吧! 当然 我们也可以自定义线程池来适用不同的业务场景。

猜你喜欢

转载自juejin.im/post/7016264133330862087