线程池初探

本文涉及的产品
RDS MySQL DuckDB 分析主实例,集群系列 4核8GB
RDS AI 助手,专业版
简介: 线程池通过复用线程提升性能,避免频繁创建销毁的开销。它统一管理线程,减少资源消耗与上下文切换,简化多线程编程。使用时只需提交任务,无需关注线程生命周期,支持定时、周期性任务调度,是高效稳定的并发编程工具。(238字)

所谓线程池,就是将多个线程放在一个池子里面(所谓池化技术),然后需要线程的时候不是创建一个线程,而是从线程池里面获取一个可用的线程,然后执行我们的任务。线程池的关键在于它为我们管理了多个线程,我们不需要关心如何创建线程,我们只需要关系我们的核心业务,然后需要线程来执行任务的时候从线程池中获取线程。任务执行完之后线程不会被销毁,而是会被重新放到池子里面,等待机会去执行任务。
我们为什么需要线程池呢?首先一点是线程池为我们提高了一种简易的多线程编程方案,我们不需要投入太多的精力去管理多个线程,线程池会自动帮我们管理好,它知道什么时候该做什么事情,我们只要在需要的时候去获取就可以了。其次,我们使用线程池很大程度上归咎于创建和销毁线程的代价是非常昂贵的,甚至我们创建和销毁线程的资源要比我们实际执行的任务所花费的时间还要长,这显然是不科学也是不合理的,而且如果没有一个合理的管理者,可能会出现创建了过多的线程的情况,也就是在JVM中存活的线程过多,而存活着的线程也是需要销毁资源的,另外一点,过多的线程可能会造成线程过度切换的尴尬境地。
对线程池有了一个初步的认识之后,我们来看看如何使用线程池。

  1. 创建一个线程池

ExecutorService executorService = Executors.newFixedThreadPool(1);

  1. 提交任务

executorService.submit(() -> System.out.println("run"));
Future stringFuture = executorService.submit(() -> "run");

  1. 创建一个调度线程池

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);

  1. 提交一个周期性执行的任务

scheduledExecutorService
.scheduleAtFixedRate(() -> System.out.println("schedule"), 0, 1, TimeUnit.SECONDS);

  1. shutdown

executorService.shutdownNow();
scheduledExecutorService.shutdownNow();

可以发现使用线程池非常简单,只需要极少的代码就可以创建出我们需要的线程池,然后将我们的任务提交到线程池中去。我们只需要在结束之时记得关闭线程池就可以了。本文的重点并非在于如何使用线程池,而是试图剖析线程池的实现,比如一个调度线程池是怎么实现的?是靠什么实现的?为什么能这样实现等等问题。

相关文章
|
消息中间件 物联网 网络性能优化
MQTT常见问题之mqtt 连接一直显示 Not authorized to connect如何解决
MQTT(Message Queuing Telemetry Transport)是一个轻量级的、基于发布/订阅模式的消息协议,广泛用于物联网(IoT)中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总:
|
2月前
|
物联网 网络安全 数据安全/隐私保护
DDoS 攻击的最新趋势
僵尸网络利用物联网设备发起大规模DDoS攻击,结合应用层、加密流量和高强度体积攻击,不断突破防御极限。从Dyn到AWS事件,攻击峰值已达2.3 Tbps,威胁持续升级。
|
2月前
|
数据安全/隐私保护
RBAC权限模型
RBAC(基于角色的访问控制)通过角色管理权限,实现用户与权限的间接关联,提升系统安全性与管理效率。其三大原则:最小权限、职责分离、数据抽象,使权限分配更清晰、灵活,广泛应用于现代权限管理系统中。
|
2月前
|
SpringCloudAlibaba Java Nacos
SpringCloud Alibaba诞生
阿里基于Spring Cloud打造Alibaba生态,推出Nacos、Sentinel、Seata等核心组件,覆盖服务发现、配置管理、流量控制与分布式事务,形成完整微服务解决方案,获Spring官方认可,推动Spring Cloud在企业级场景高效落地。
|
2月前
|
Java 大数据
ArrayList扩容机制
ArrayList添加元素时,先调用ensureCapacityInternal()确保容量,首次添加时默认扩容至10。add方法实质是为数组赋值。ensureExplicitCapacity()判断是否需扩容,当容量不足时调用grow()。grow()将容量扩大1.5倍(old + (old >> 1)),并通过Arrays.copyOf()完成数组复制。size()用于集合元素计数,length为数组属性,length()为字符串方法。
|
2月前
|
运维 Kubernetes Java
物理部署图
物理部署图描述系统运行时的硬件配置与软件部署结构,展现节点、构件、物件及连接关系,帮助理解分布式系统的网络架构与运维部署,是开发与运维协同的重要建模工具。
|
2月前
|
领域建模
领域模型图(数据架构/ER图)
数据架构核心输出为ER图,包含实体、关系与属性,用于构建数据模型。通过业务域分解与领域建模,结合四色原型法(MI红色、PPT绿色、Role黄色、DESC蓝色)抽象业务,逐步提炼系统数据架构。
|
2月前
|
uml C语言
系统时序图
时序图(Sequence Diagram)是UML中描述对象间消息传递时间顺序的交互图。横轴为对象,纵轴为时间,通过生命线、控制焦点和消息展示动态协作。支持同步、异步与返回消息,可直观表达并发过程与方法调用,是分析系统行为的重要工具。(238字)
分布式应用架构
分布式应用架构图展示产品内部及与外部系统的应用调用关系,体现SOA架构下的逻辑与通信连接。重点呈现应用间的内外部依赖,清晰反映产品在整体业务中的定位与影响,不包含服务注册、治理等RPC技术细节。(238字)
|
2月前
|
开发框架 微服务
应用架构图
在业务架构基础上,技术架构承接应用需求,明确技术选型与分层设计。涵盖开发语言、框架、微服务分层及非功能性需求,通过关键技术选型与层级关系梳理,形成完整的技术架构图,实现产品需求到技术落地的转化。(238字)