Java创建线程池的方式

共 2705字,需浏览 6分钟

 ·

2022-03-11 12:41

一、创建线程池的方式一般有两种:

  1. 通过Executors工厂方法创建

  2. 通过 newThreadPoolExecutor(intcorePoolSize,intmaximumPoolSize,longkeepAliveTime,TimeUnitunit,BlockingQueue<Runnable>workQueue,new ThreadFactoryBuilder().setNameFormat("thread-name-%").build(), newThreadPoolExecutor.AbortPolicy())

二、通过Executors工厂创建

1. Executors.newSingleThreadExecutor()

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

  1. publicstaticExecutorService newSingleThreadExecutor(){

  2. returnnewFinalizableDelegatedExecutorService

  3. (newThreadPoolExecutor(1,1,

  4. 0L,TimeUnit.MILLISECONDS,

  5. newLinkedBlockingQueue<Runnable>()));

  6. }

  • corePoolSize:1,只有一个核心线程在工作

  • maximumPoolSize:1

  • keepAliveTime:0L

  • TimeUnit: TimeUnit.MILLISECONDS 时间单位是毫秒

  • workQueue:new LinkedBlockingQueue(),其缓冲队列是无界的

2. Executors.newFixedThreadPool(n)

FixedThreadPool 是固定大小的线程池,只有核心线程。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。FixedThreadPool 多数针对一些很稳定很固定的正规并发线程,多用于服务器。

  1. publicstaticExecutorService newFixedThreadPool(int nThreads){

  2. returnnewThreadPoolExecutor(nThreads, nThreads,

  3. 0L,TimeUnit.MILLISECONDS,

  4. newLinkedBlockingQueue<Runnable>());

  5. }

  • corePoolSize:nThreads

  • maximumPoolSize:nThreads

  • keepAliveTime:0L

  • TimeUnit: TimeUnit.MILLISECONDS 时间单位是毫秒

  • workQueue:new LinkedBlockingQueue(),其缓冲队列是无界的

3. Executors.newCachedThreadPool()

CachedThreadPool 是无界线程池,如果线程池的大小超过了处理任务所需要的线程,那么就会回收部分空闲(60 秒不执行任务)线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。线程池大小完全依赖于操作系统(或者说 JVM)能够创建的最大线程大小。SynchronousQueue 是一个是缓冲区为 1 的阻塞队列。缓存型池子通常用于执行一些生存期很短的异步型任务,因此在一些面向连接的 daemon 型 SERVER 中用得不多。但对于生存期短的异步任务,它是 Executor 的首选。

  1. publicstaticExecutorService newCachedThreadPool(){

  2. returnnewThreadPoolExecutor(0,Integer.MAX_VALUE,

  3. 60L,TimeUnit.SECONDS,

  4. newSynchronousQueue<Runnable>());

  5. }

  • corePoolSize:0

  • maximumPoolSize:Integer.MAX_VALUE

  • keepAliveTime:60L

  • TimeUnit: TimeUnit.SECONDS时间单位是秒

  • workQueue:new SynchronousQueue(),一个是缓冲区为 1 的阻塞队列。

4. Executors.newScheduledThreadPool(n)

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

  1. publicScheduledThreadPoolExecutor(int corePoolSize){

  2. super(corePoolSize,Integer.MAX_VALUE,0, NANOSECONDS,

  3. newDelayedWorkQueue());

  4. }

  • corePoolSize:corePoolSize

  • maximumPoolSize:Integer.MAX_VALUE

  • keepAliveTime:DEFAULTKEEPALIVEMILLIS

  • workQueue:new DelayedWorkQueue()

三、通过new ThreadPoolExecutor(coreThreadSize, max... ...)

具体的详情请看之前的文章线程池的理解以及使用


本文作者:Java技术债务
原文链接:https://www.cuizb.top/myblog/article/1646793688
版权声明: 本博客所有文章除特别声明外,均采用 CC BY 3.0 CN协议进行许可。转载请署名作者且注明文章出处。

Java技术债务


1140333905492948723ffbefe482fb78.webp

JVM内存泄漏和内存溢出的原因
JVM常用监控工具解释以及使用

Redis 常见面试题(一)

ClickHouse之MaterializeMySQL引擎(十)

三种实现分布式锁的实现与区别

线程池的理解以及使用


号外!号外!最近面试BAT,整理一份面试资料,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。想获取吗?如果你想提升自己,并且想和优秀的人一起进步,感兴趣的朋友,可以在扫码关注下方公众号。资料在公众号里静静的躺着呢。。。



喜欢就分享
认同就点赞

支持就在看

一键四连,你的offer也四连3bdd8f73850e4943a8c131e0e6c6b8bd.webp

浏览 23
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报