总结线程池

什么是线程池

线程池(Thread Pool)是一种用于管理和复用线程的技术,它可以在多线程编程中有效地管理线程的创建、执行和销毁。是一种有效管理线程的机制,可以提高多线程编程的效率、性能和资源利用率。它在许多并发编程的场景中被广泛使用,如服务器端程序、并行计算、异步任务等。

线程池的好处包括

  1. 提高性能:由于线程的创建和销毁是一项耗时的操作,使用线程池可以避免频繁地创建和销毁线程,提高了程序的性能。

  2. 资源管理:线程池可以限制线程的数量,避免线程过多导致系统资源的浪费和性能下降。

  3. 控制并发度:通过控制线程池的大小,可以限制并发任务的数量,避免系统资源过载和响应时间过长的问题。

  4. 提供任务排队和调度:线程池可以对任务进行排队和调度,确保任务按照一定的顺序和优先级执行。

线程池的参数详细介绍

  1. 核心线程数(corePoolSize):核心线程数是线程池中保持活动状态的线程数量。在没有任务执行时,核心线程会一直保持存活状态。如果任务数量超过核心线程数,线程池会创建新的线程来执行任务。

  2. 最大线程数(maximumPoolSize):最大线程数是线程池中允许存在的最大线程数量。当任务数量超过核心线程数且任务队列已满时,线程池会创建新的线程,直到达到最大线程数。超过最大线程数的任务会根据配置的拒绝策略进行处理。

  3. 空闲线程存活时间(keepAliveTime):当线程池中的线程数量超过核心线程数时,多余的空闲线程会在一定时间内保持活动状态,等待新的任务。keepAliveTime 是空闲线程的存活时间,超过这个时间线程会被销毁,直到线程池的线程数量不超过核心线程数。

  4. 时间单位(TimeUnit):对于核心线程数、最大线程数和空闲线程存活时间,通常需要指定一个时间单位,如秒、毫秒等。

  5. 任务队列(workQueue):任务队列用于存储待执行的任务。线程池根据任务数量和线程池状态来决定任务的执行方式。常见的任务队列有无界队列和有界队列,如 LinkedBlockingQueue 和 ArrayBlockingQueue。

  6. 线程工厂(threadFactory):线程工厂用于创建新的线程实例。通过指定线程工厂,可以自定义线程的一些属性,如名称、优先级等。

  7. 拒绝策略(rejectedExecutionHandler):当任务数量超过线程池的最大线程数时,线程池会对新的任务采取一定的拒绝策略。常见的拒绝策略有直接抛出异常、丢弃任务、丢弃最旧的任务和调用者运行等。

正确地配置线程池参数可以避免线程过多或过少导致的性能问题,并提高任务的处理效率和并发度。

若把创建一个线程池想象成开个公司. 每个员工相当于一个线程.则:

corePoolSize: 正式员工的数量. (正式员工, 一旦录用, 永不辞退)
maximumPoolSize: 正式员工 +临时工的数目. (临时工: 一段时间不干活, 就被辞退).
keepAliveTime: 临时工允许的空闲时间. unit:
keepaliveTime 的时间单位, 是秒, 分钟, 还是其他值.
workQueue: 传递任务的阻塞队列
threadFactory: 创建线程的工厂, 参与具体的创建线程工作

RejectedExecutionHandler: 拒绝策略,如果任务量超出公司的负荷了接下来怎么处理.
AbortPolicy(): 超过负荷, 直接抛出异常.
CallerRunsPolicy(): 调用者负责处理
DiscardOldestPolicy(): 丢弃队列中最老的任务.
DiscardPolicy(): 丢弃新来的任务.

线程池的工作流程

  1. 创建线程池:在使用线程池之前,首先需要创建一个线程池实例。线程池可以使用编程语言或框架提供的相关API来创建,通常需要指定线程池的参数,如核心线程数、最大线程数、任务队列等。

  2. 提交任务:一旦线程池创建完成,就可以将需要执行的任务提交给线程池。任务可以是用户定义的代码块、函数或对象。任务的提交可以通过调用线程池提供的提交方法进行。

  3. 任务排队:当任务提交到线程池后,线程池会将任务添加到任务队列中。任务队列可以是有界队列或无界队列,它负责存储待执行的任务。

  4. 线程分配:线程池中的线程管理器会管理和分配线程。如果当前线程池中的线程数小于核心线程数,线程池会创建新的线程来执行任务。如果线程池中的线程数已经达到核心线程数,新的任务将被放入任务队列中等待执行。

  5. 任务执行:空闲的线程会从任务队列中取出任务,开始执行任务的代码。当一个线程执行完一个任务后,它会继续从任务队列中获取下一个任务并执行,直到任务队列为空。

  6. 拒绝策略:如果任务队列已满且线程池中的线程数已达到最大线程数,新提交的任务可能会被线程池拒绝。线程池会根据配置的拒绝策略来处理这些被拒绝的任务,可以选择抛出异常、丢弃任务、丢弃队列中最旧的任务或者由调用者线程执行任务。

  7. 线程回收:如果线程池中的线程处于空闲状态,并且超过了指定的空闲线程存活时间,这些空闲线程会被终止并从线程池中移除,以减少资源消耗。

使用Executors 创建常见的线程池

newFixedThreadPool: 创建固定线程数的线程池
newCachedThreadPool: 创建线程数目动态增长的线程池.
newSingleThreadExecutor:创建只包含单个线程的线程池.
newScheduledThreadPool: 设定 延迟时间后执行命令,或者定期执行命令. 是进阶版的
Timer.

Executors 本质上是 ThreadPoolExecutor 类的封装.
使用newFixedThreadPool工厂方法创建“固定数量的线程池”:

public static ExecutorService newFixedThreadPool(int nThreads) {return new ThreadPoolExecutor(nThreads, // 核心线程数nThreads, // 最大线程数0L, // 线程最大空闲(Idle)时长TimeUnit.MILLISECONDS, // 时间单位:毫秒new LinkedBlockingQueue<Runnable>() //任务的排队队列,无界队列);}

newSingleThreadExecutor

public static ExecutorService newSingleThreadExecutor() {return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, // 核心线程数1, // 最大线程数0L, // 线程最大空闲(Idle)时长TimeUnit.MILLISECONDS, //时间单位:毫秒new LinkedBlockingQueue<Runnable>() //无界队列));}

newCachedThreadPool

public static ExecutorService newCachedThreadPool(){return new ThreadPoolExecutor(0, // 核心线程数Integer.MAX_VALUE, // 最大线程数60L, // 线程最大空闲(Idle)时长TimeUnit.MILLISECONDS, // 时间单位:毫秒new SynchronousQueue<Runnable>() // 任务的排队队列,无界队列);}

newScheduledThreadPool

public ScheduledThreadPoolExecutor(int corePoolSize) {super(corePoolSize, // 核心线程数Integer.MAX_VALUE,  // 最大线程数0, //线程最大空闲(Idle)时长NANOSECONDS,//时间单位new DelayedWorkQueue() //任务的排队队列);}

使用Executors创建的"可缓存线程池"没有固定的线程数量限制,它会根据任务的到来自动创建线程。如果任务的到来速度过快,线程池可能会不断地创建新线程,导致线程数无限增长。这可能会消耗大量的系统资源,甚至导致系统崩溃。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/30013.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【设计模式】-建造者模式

Java建造者模式&#xff1a;创建复杂对象的灵活构建者 在软件开发中&#xff0c;我们经常遇到需要创建一个复杂对象的情况。如果使用传统的构造函数进行对象创建&#xff0c;可能会导致构造函数参数过多&#xff0c;难以管理和维护。建造者模式&#xff08;Builder Pattern&am…

数据结构-队列(C语言的简单实现)

简介 队列也是一种数据结构&#xff0c;队列也可以用来存放数字每次只能向队列里将入一个数字&#xff0c;每次只能从队列里获得一个数字在队列中&#xff0c;允许插入的一段称为入队口&#xff0c;允许删除的一段称为出队口它的原则是先进先出(FIFO: first in first out)&…

Docker之jenkins部署harbor在harbor中完成部署

Docker之jenkins部署harbor在harbor中完成部署 1、harbor作用 Harbor允许用户用命令行工具对容器镜像及其他Artifact进行推送和拉取&#xff0c;并提供了图形管理界面帮助用户查阅和删除这些Artifact。在Harbor 2.0版本中&#xff0c;除容器镜像外&#xff0c;Harbor对符合OCI…

商品推荐系统浅析 | 京东云技术团队

一、综述 本文主要做推荐系统浅析&#xff0c;主要介绍推荐系统的定义&#xff0c;推荐系统的基础框架&#xff0c;简单介绍设计推荐的相关方法以及架构。适用于部分对推荐系统感兴趣的同学以及有相关基础的同学&#xff0c;本人水平有限&#xff0c;欢迎大家指正。 二、商品…

灰度线性变换之c++实现(qt + 不调包)

1.介绍 灰度线性变化是最常用的点运算&#xff08;对每个像素进行运算&#xff09;操作之一&#xff0c;灰度线性变化就是将图片的像素值通过指定的线性函数进行变换&#xff0c;以此增强或者减弱图片的灰度。灰度线性变换的公式就是常见的一维线性函数&#xff1a; y_out k…

Spring中参数校验@Validation注解的详细介绍

在Spring框架中&#xff0c;Valid 注解是一个强大的工具&#xff0c;用于验证和校验用户输入的数据&#xff0c;确保数据的合法性和完整性。通过结合其他注解和验证器&#xff0c;Valid 注解可以轻松地实现数据验证&#xff0c;从而提高应用程序的健壮性和安全性。本文将详细介…

【ChatGPT 指令大全】怎么使用ChatGPT辅助程式开发

目录 写程式 解读程式码 重构程式码 解 bug 写测试 写 Regex 总结 在当今快节奏的数字化世界中&#xff0c;程式开发变得越来越重要和普遍。无论是开发应用程序、网站还是其他软件&#xff0c;程式开发的需求都在不断增长。然而&#xff0c;有时候我们可能会遇到各种问题…

直播课 | 大橡科技研发总监丁端尘博士“类器官芯片技术在新药研发中的应用”

从类器官到类器官芯片&#xff0c;正在生物科学领域大放异彩。 药物研发需要新方法 众所周知&#xff0c;一款新药是一个风险大、周期长、成本高的艰难历程&#xff0c;国际上有一个传统的“双十”说法——10年时间&#xff0c;10亿美金&#xff0c;才可能成功研发出一款新药…

SpringCloud实用篇4——MQ RabbitMQ SpringAMQP

目录 1 初识MQ1.1 同步和异步通讯1.1.1 同步通讯1.1.2 异步通讯 1.2 技术对比 2.快速入门2.1 安装RabbitMQ2.1.1 单机部署2.1.2集群部署 2.2 RabbitMQ消息模型2.3.导入Demo工程2.4 入门案例2.4.1 publisher实现2.4.2 consumer实现 3 SpringAMQP3.1 Basic Queue 简单队列模型3.1…

玩一玩通义千问Qwen开源版,Win11 RTX3060本地安装记录!

大概在两天前&#xff0c;阿里做了一件大事儿。 就是开源了一个低配版的通义千问模型--通义千问-7B-Chat。 这应该是国内第一个大厂开源的大语言模型吧。 虽然是低配版&#xff0c;但是在各类测试里面都非常能打。 官方介绍&#xff1a; Qwen-7B是基于Transformer的大语言模…

Java EE 突击 9 - Spring Boot 日志文件

Spring Boot 日志文件 学习目标一 . 日志有什么用1.1 日志格式说明 二 . 自定义日志打印2.1 得到日志对象2.2 使用日志对象提供的方法 , 输出自定义的日志内容2.3 日志的级别 三 . 日志持久化3.1 在配置文件里面设置日志名称3.2 设置日志的保存目录 四 . 日志级别的设置五 . 简…

js有哪些内置对象

全局的对象或称为标准内置对象&#xff0c;不要和“全局对象”混淆&#xff0c;这里说的全局的对象是说在全局作用域里的对象。全局作用域中的其他对象可以由用户创建的脚本创建或由宿主程序提供。 Object Object:js中所有对象都是由Object构造函数创建的。它提供了对象的基本功…

flutter 手写日历组件

先看效果 直接上代码 calendar_popup_view.dart import package:flutter/material.dart; import package:intl/intl.dart;import custom_calendar.dart; import hotel_app_theme.dart;class CalendarPopupView extends StatefulWidget {const CalendarPopupView({required th…

【【萌新的STM32 学习-6】】

萌新的STM32 学习-6 BSP 文件夹&#xff0c;用于存放正点原子提供的板级支持包驱动代码&#xff0c;如&#xff1a;LED、蜂鸣器、按键等。 本章我们暂时用不到该文件夹&#xff0c;不过可以先建好备用。 CMSIS 文件夹&#xff0c;用于存放 CMSIS 底层代码&#xff08;ARM 和 ST…

Spring 是什么框架?

Spring 是 Java EE 编程领域的一款轻量级的开源框架&#xff0c;由被称为“Spring 之父”的 Rod Johnson 于 2002 年提出并创立&#xff0c;它的目标就是要简化 Java 企业级应用程序的开发难度和周期。 Spring 自诞生以来备受青睐&#xff0c;一直被广大开发人员作为 Java 企业…

AUTOSAR规范与ECU软件开发(基础篇)1.1汽车电子控制系统介绍

目录 前言 1 电子技术在汽车上的应用 1.1 汽车电子技术的发展历史

winrar压缩命令实例

"C:\Program Files\WinRAR\WinRAR.exe" a -ibck -ag -r -m3 -x*\bin\ -x*\obj\ -x*\publish\ -x"abc.csproj.user" abc.rar * a 添加文件到压缩文件夹 -ibck 在后台运行 WinRAR -ag 表示当创建压缩…

深度学习之用PyTorch实现逻辑回归

0.1 学习视频源于&#xff1a;b站&#xff1a;刘二大人《PyTorch深度学习实践》 0.2 本章内容为自主学习总结内容&#xff0c;若有错误欢迎指正&#xff01; 代码&#xff08;类比线性回归&#xff09;&#xff1a; # 调用库 import torch import torch.nn.functional as F#…

2023安全与软工顶会/刊中区块链智能合约相关论文

2023安全与软工顶会/刊中区块链智能合约相关论文 前言软工顶会ISSTAFSEASEICSE 软工顶刊TOSEMTSE 安全顶会S&PUSENIX SecurityCCSNDSS 前言 主要整理了2023年四大安全顶会、四大软工顶会和两个软工顶刊中&#xff0c;有关区块链智能合约的相关论文。 搜索方式是&#xff1…

HDFS小文件解决方案---archive归档文件命令

小文件解决方案 背景Archive概述创建archive查看归档文件查看归档之后的样子查看归档文件之前的样子 提取archivearchive注意事项 背景 hdfs并不擅长存储小文件&#xff0c;因为每个文件最少一个block&#xff0c;每个block的元数据都会在namenode占用内存&#xff0c;如果存在…