当前位置：首页 > 科技 > 软件

四种常见线程池的原理，你学会了吗？

来源：责编：时间：2023-10-30 17:24:14 183观看

导读newFixedThreadPool (固定数目线程的线程池)newCachedThreadPool (可缓存线程的线程池)newSingleThreadExecutor (单线程的线程池)newScheduledThreadPool (定时及周期执行的线程池)前三种线程池的构造直接调用Thread

newFixedThreadPool (固定数目线程的线程池)

newCachedThreadPool (可缓存线程的线程池)

newSingleThreadExecutor (单线程的线程池)

newScheduledThreadPool (定时及周期执行的线程池)

前三种线程池的构造直接调用ThreadPoolExecutor的构造方法。

newSingleThreadExecutor

public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {  return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1,0L,TimeUnit.MILLISECONDS,  	new LinkedBlockingQueue<Runnable>(),threadFactory));}

线程池特点：

核心线程数：1

最大线程数：1

阻塞队列是无界队列LinkedBlockingQueue，可能会导致OOM

keepAliveTime：0

工作流程：

1、提交任务

2、线程池是否有一条线程在，如果没有，新建线程执行任务

3、如果有，将任务加到阻塞队列

4、当前的唯一线程，从队列取任务，执行完一个，再继续，一个线程执行任务

适用场景：

适用于串行执行任务的场景，一个任务一个任务地执行

newFixedThreadPool

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {  return new ThreadPoolExecutor(nThreads, nThreads,0L,TimeUnit.MILLISECONDS,  	new LinkedBlockingQueue<Runnable>(), threadFactory);}

线程池特点：

核心线程数和最大线程数大小一样；

没有所谓的非空闲时间，即keepAliveTime为0；

阻塞队列为无界队列LinkedBlockingQueue，可能会导致OOM；

工作流程：

1、提交任务；

2、如果线程数少于核心线程，创建核心线程执行任务；

3、如果线程数等于核心线程，把任务添加到LinkedBlockingQueue阻塞队列；

4、如果线程执行完任务，去阻塞队列取任务，继续执行。

适用场景：

FixedThreadPool适用于处理CPU密集型的任务，确保CPU在长期被工作线程使用的情况下，尽可能少的分配线程，即适用执行长期的任务。

newCachedThreadPool

public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {  return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS,  	new SynchronousQueue<Runnable>(), threadFactory);}

线程池特点：

核心线程数为0；

最大线程数为Integer.MAX_VALUE，即无限大，可能会因为无线创建线程，导致OOM

阻塞队列是SynchronousQueue

非核心线程空闲存活时间为60s

当提交任务速度大于处理任务的速度时，每次提交一个任务，就必然会创建一个线程。

极端情况下会创建过多的线程，耗尽CPU和内存资源。由于空闲60秒的线程会被终止，长时间保持空闲的CachedThreadPool不会占用任何资源。

工作流程：

提交任务；

因为没有核心线程，所以任务会直接加到SynchronousQueue队列；

判断是否有空闲线程，如果有，就去取出任务执行；

如果没有空闲线程，就新建一个线程执行；

执行完任务的线程，还可以存活60s，如果在这期间接到任务，就可以继续活下去，否则被销毁。

适用场景：

用于并发执行大量短期的小任务。

newScheduleThreadPool

public ScheduledThreadPoolExecutor(int corePoolSize) {  super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS, new DelayedWorkQueue());}

线程池特点：

最大线程数为Integer.MAX_VALUE，也有OOM风险

阻塞队列是DelayedWorkQueue

keepAliveTime为0

scheduleAtFixedRate（）：按某种速率周期执行

scheduleWithFixedDelay（）：在某个延迟后执行

工作机制：

线程从DelayQueue中获取已到期的ScheduledFutureTask（DelayQueue.take()）。到期任务是指ScheduledFutureTask的time大于等于当前时间。

线程执行这个ScheduleFutureTask

线程修改ScheduledFutureTask的time变量为下次将要被执行的时间

线程把这个修改time之后的ScheduledFutureTask放回DelayQueue中（DelayQueue.add()）。

使用场景：

周期性执行任务的场景，需要限制线程数量的场景。

使用无界队列的线程池会导致什么问题：

例如newFixedThreadPool使用了无界的阻塞队列LinkedBlockingQueue，如果线程获取一个任务后，任务的执行时间比较长，会导致队列的任务越积越多，导致机器内存使用不停飙升，最终导致OOM。

本文链接：http://www.28at.com/showinfo-26-15863-0.html四种常见线程池的原理，你学会了吗？

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：使用Frida在Windows中拦截C++函数

下一篇： Kubernetes使用OkHttp客户端进行网络负载均衡

标签：

热门焦点

石头自清洁扫拖机器人G10S评测：多年黑科技集大成之作懒人终极福音

科技圈经常能看到一个词叫“缝合怪”，用来形容那些把好多功能或者外观结合在一起的产品，通常这样的词是贬义词，但如果真的是产品缝合的好、缝合的实用的话，那它就成了中性词，今
Flowable工作流引擎的科普与实践

一.引言当我们在日常工作和业务中需要进行各种审批流程时，可能会面临一系列技术和业务上的挑战。手动处理这些审批流程可能会导致开发成本的增加以及业务复杂度的上升。在这
微信语音大揭秘：为什么禁止转发？

大家好，我是你们的小米。今天，我要和大家聊一个有趣的话题：为什么微信语音不可以转发？这是一个我们经常在日常使用中遇到的问题，也是一个让很多人好奇的问题。让我们一起来揭开这
10天营收超1亿美元，《星铁》比《原神》差在哪？

来源：伯虎财经作者：陈平安即便你没玩过《原神》，你一定听说过的它的大名。恨它的人把《原神》开服那天称作是中国游戏史上最黑暗的一天，有粉丝因为索尼在PS平台上线《原神》，怒而
猿辅导与新东方的两种“归途”

作者｜卓心月出品｜零态LT（ID：LingTai_LT）如何成为一家伟大企业？答案一定是对“势”的把握，这其中最关键的当属对企业战略的制定，且能够站在未来看现在，即使这其中的
苹果公司要求三星和LG Display生产「无边框」OLED iPhone显示屏

据 The Elec 报道，苹果已要求其供应商为未来的 iPhone 型号开发「无边框」OLED 显示面板。苹果显然已要求三星和 LG Display 开发新的 OLED 显示面
引领旗舰级影像能力向中端机普及 OPPO K11 系列发布 1799 元起

7月25日，OPPO正式发布K系列新品—— OPPO K11 。此次 K11 在中端手机市场长期被忽视的影像板块发力，突破性地搭载索尼 IMX890 旗舰大底主摄，支持 OIS
质感不错！OPPO K11渲染图曝光：旗舰IMX890传感器首次下放

一直以来，OPPO K系列机型都保持着较为均衡的产品体验，历来都是2K价位的明星机型，去年推出的OPPO K10和OPPO K10 Pro两款机型凭借各自的出色配置，堪称有
电博会与软博会实现"线下+云端"的双线融合

在本次“电博会”与“软博会”双展会利好条件的加持下，既可以发挥展会拉动人流、信息流、资金流实现快速交互流动的作用，继而推动区域经济良性发展；又可以聚