首页 > 其他分享 >线程池原理

线程池原理

时间:2024-07-01 16:43:07浏览次数:1  
标签:调用 队列 阻塞 任务 线程 TimeUnit 原理

3 线程池原理

3.1 ctl

private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));

是原子变量,同时记录线程池状态和线程池线程个数
以32位为例,高三位表示状态,后面表示个数

3.2 状态

Running:接受新任务并处理阻塞队列里任务
shutdown:拒绝新任务但是处理队列任务
stop:拒绝并抛弃阻塞队列任务,同时中断处理任务
tidying:所有任务都执行完,活动线程为0,将要调用terminated方法
terminated:终止状态

  • 状态转换
    run->shut:显式调用shutdown,隐式调用finalize
    run/shut->stop:显式调用shutdownNow
    shut->tidy:线程池和任务队列都为空
    stop->tidy:线程池为空
    tidy->terminated:执行terminated

3.3 线程池参数

  • corePoolSize:核心线程数
    线程池维护的最小线程数量,核心线程创建后不会被回收(注意:设置allowCoreThreadTimeout=true后,空闲的核心线程超过存活时间也会被回收)。
    大于核心线程数的线程,在空闲时间超过keepAliveTime后会被回收。
    线程池刚创建时,里面没有一个线程,当调用 execute() 方法添加一个任务时,如果正在运行的线程数量小于corePoolSize,则马上创建新线程并运行这个任务。

  • maximumPoolSize:最大线程数
    线程池允许创建的最大线程数量。
    当添加一个任务时,核心线程数已满,线程池还没达到最大线程数,并且没有空闲线程,工作队列已满的情况下,创建一个新线程并执行。

  • keepAliveTime:空闲线程存活时间
    当一个可被回收的线程的空闲时间大于keepAliveTime,就会被回收。
    可被回收的线程:设置allowCoreThreadTimeout=true的核心线程和大于核心线程数的线程(非核心线程)。
    unit:时间单位:keepAliveTime的时间单位:
    TimeUnit.NANOSECONDS
    TimeUnit.MICROSECONDS
    TimeUnit.MILLISECONDS // 毫秒
    TimeUnit.SECONDS
    TimeUnit.MINUTES
    TimeUnit.HOURS
    TimeUnit.DAYS

  • workQueue:工作队列
    存放待执行任务的队列:当提交的任务数超过核心线程数大小后,再提交的任务就存放在工作队列,任务调度时再从队列中取出任务。
    它仅仅用来存放被execute()方法提交的Runnable任务。工作队列实现了BlockingQueue接口。
    JDK默认的工作队列有五种:
    ArrayBlockingQueue 数组型阻塞队列:数组结构,初始化时传入大小,有界,FIFO,使用一个重入锁,默认使用非公平锁,入队和出队共用一个锁,互斥。
    LinkedBlockingQueue 链表型阻塞队列:链表结构,默认初始化大小为Integer.MAX_VALUE,有界(近似无解),FIFO,使用两个重入锁分别控制元素的入队和出队,用Condition进行线程间的唤醒和等待。
    SynchronousQueue 同步队列:容量为0,添加任务必须等待取出任务,这个队列相当于通道,不存储元素。
    PriorityBlockingQueue 优先阻塞队列:无界,默认采用元素自然顺序升序排列。
    DelayQueue 延时队列:无界,元素有过期时间,过期的元素才能被取出。

  • threadFactory:线程工厂
    创建线程的工厂,可以设定线程名、线程编号等。

  • dafaultHandler:拒绝策略
    当线程池线程数已满,并且工作队列达到限制,新提交的任务使用拒绝策略处理。可以自定义拒绝策略,拒绝策略需要实现RejectedExecutionHandler接口。
    JDK默认的拒绝策略有四种:
    AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
    DiscardPolicy:丢弃任务,但是不抛出异常。可能导致无法发现系统的异常状态。
    DiscardOldestPolicy:丢弃队列最前面的任务,然后重新提交被拒绝的任务。
    CallerRunsPolicy:由调用线程处理该任务。

3.4 其他变量和类

mainLock独占锁,用来控制新增Worker线程的原子性
termination是该锁对应条件队列,在线程调用awaitTermination时存放阻塞队列
Worker类继承AQS和Runnable接口,是具体承载任务的对象。
AQS实现简单不可重入独占锁
DefaultThreadFactory是线程工厂,

标签:调用,队列,阻塞,任务,线程,TimeUnit,原理
From: https://www.cnblogs.com/lwx11111/p/18278371

相关文章

  • 深入MySQL锁机制:原理、死锁解决及Java防范技巧
    引言在数据库系统中,锁机制是为了保证数据一致性和完整性的重要手段。MySQL作为广泛使用的关系型数据库管理系统,其锁机制尤为重要。本文将详细介绍MySQL的锁机制原理及实现,并说明在生产环境中如何解决死锁问题,以及在后续开发中如何编写Java代码避免死锁。MySQL锁机制概述MySQ......
  • k8s-11-Kubernetes原理
    Kubernetes原理控制平面负责控制并使得整个集群正常运行。Etcd分布式持久化存储API服务器调度器控制器管理器工作节点负责容器的运行任务kubeletkube-proxy容器运行时(Docker、rkt等)附加组件DNS服务器仪表盘Ingress控制器Heapster(容器集群监控)容器......
  • spring 定时任务 使用线程池
    spring线程池定义packagecom.minex.icp.tool.conf;importlombok.extern.slf4j.Slf4j;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.scheduling.annotation.AsyncConfi......
  • 揭秘LLaMA 2:深度学习的未来,从原理到模型训练的全面剖析
    引言LLaMA(LargeLanguageModelforAIAssistance)2是Meta(原Facebook)开发的一个大型语言模型,旨在为各种自然语言处理任务提供强大的支持。它在前代基础上进行了改进,具有更好的性能和更广泛的应用前景。本文将详细介绍LLaMA2的原理、模型结构和训练方法。目录LLaMA......
  • mybatis 查询原理
    mybatis所有操作都会通过sqlSession来完成publicinterfaceSqlSessionextendsCloseable{<T>TselectOne(Stringvar1);<T>TselectOne(Stringvar1,Objectvar2);<E>List<E>selectList(Stringvar1);<E>List<E>......
  • ​RAG与LLM原理及实践(7)--- Chroma query应用层策略及实现原理
    背景Chromaquery底层查询的 query思想是相同的,甚至在vectordb的世界中,都大同小异。如果你有看前面写的  RAG与LLM原理及实践(5)---Chromaquery源码分析应该比较清楚query的运作原理,说直白就是在memory或是disk中通过暴力查询比较与HNSW算法(NSW算法的变种,分层可导航......
  • RAG与LLM原理及实践(6)--- Chroma collection及存储逻辑分析
     背景在chromavectordb的世界中,除了对query的理解,另外就是需要深入理解chroma的运行模式,chroma运行时,提供了 local模式,server-client模式,这些在应用中固然重要,但从实现原理上说,其实就是通过http服务,在固定端口如11344上请求数据。但是在这之前,需要深入了解并理解coll......
  • RAG与LLM原理及实践(4)--- 语义相似度距离衡量的三种方式chroma示例
    语义相似度的计算是一个比较复杂的过程。今天打算先比较详细的介绍下几个相似度的距离衡量算法。相似度的排名衡量,在向量数据库vectordb的query中,被大量使用。还是直接上干货,理解下背后的逻辑和概念比较重要,后面看看源码 chromavectordb是怎么处理这个过程的。1)co......
  • BeanFactoryAware原理机制
    BeanFactoryAware是Spring框架中的一个接口,它允许一个bean在其初始化时感知到其所在的BeanFactory。这通常用于在bean内部进行一些高级配置或访问Spring容器中的其他bean。简单使用当你实现BeanFactoryAware接口时,你需要实现setBeanFactory(BeanFactoryb......
  • 降维 (Dimensionality Reduction) 原理与代码实例讲解
    降维(DimensionalityReduction)原理与代码实例讲解作者:禅与计算机程序设计艺术/ZenandtheArtofComputerProgramming关键词:降维技术,数据可视化,特征选择,PCA,t-SNE,SVD,机器学习1.背景介绍1.1问题的由来在数据分析和机器学习领域,面对高维度的数据集是一个普遍且......