ScheduledThreadPoolExecutor实现原理解析

2024-05-28 17:32

本文主要是介绍ScheduledThreadPoolExecutor实现原理解析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

原文地址:《ScheduledThreadPoolExecutor实现原理解析》

1、什么是ScheduledThreadPoolExecutor

通熟的来就是一个线程池,只不过这个线程池中的所有工作线程需要处理的都是计划任务,这个任务分为两种,一种是重复任务,一种是一次性任务,所谓一次性任务,基本上是指定在提交任务多长时间之后开始执行,而重复性任务就是在任务被执行完成之后,在一定的时间间隔之后还会被执行,重复任务具体什么时候被执行主要与任务设置的执行时间间隔有关。而ScheuledThreadPoolExecutor主要是被设计用来维护和调度执行计划任务的线程资源以及任务队列中任务的调整。

2、ScheduledThreadPoolExecutor和ThreadPoolExecutor有什么区别

在线程调度方面,可以说两者没有本质的区别,在核心线程的添加、任务队列的已满后,非核心工作线程的创建以及任务队列满后的任务拒绝流程方面,两种线程池没有区别。但是在一下几个方面,ScheduledThreadPoolExecutor还是有别于ThreadPoolExecutor的。

1、拥有单独定义的任务类型,详细信息可以查看ScheduledFutureTask类代码

2、使用自定义的队列,这种队列没有大小限制,在添加任务时不会因为队列中任务达到指定的数量而阻塞任务的添加,所以说它是一个无限延迟队列(队列中存放的最大任务数量为Integer.MAX_VALUE)

3、支持在线程池关闭后,移除或取消已经不能够执行的任务

3、ScheduledThreadPoolExecutor运行流程以及实现原理

关于ScheduledThreadPoolExecutor的线程调度流程以及相关工作线程创建流程与ThreadPoolExecutor的流程一致,就不重复叙述了(不清楚的可查看《ThreadPoolExecutor的实现机制》)。首先根据实力代码分析任务的提交流程,代码如下:

System.out.println("commit task...."+",time:"+String.valueOf(System.currentTimeMillis()));executorService.schedule(() ->{System.out.println("start task...."+",time:"+String.valueOf(System.currentTimeMillis()));closeThreadPool();},10000L, TimeUnit.MILLISECONDS);

使用了schedule方法提交了任务,并制定了任务开始执行时间,为当前时间延迟10秒执行。

public ScheduledFuture<?> schedule(Runnable command,long delay,TimeUnit unit) {if (command == null || unit == null)throw new NullPointerException();RunnableScheduledFuture<?> t = deco

这篇关于ScheduledThreadPoolExecutor实现原理解析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1011222

相关文章

Go语言使用sync.Mutex实现资源加锁

《Go语言使用sync.Mutex实现资源加锁》数据共享是一把双刃剑,Go语言为我们提供了sync.Mutex,一种最基础也是最常用的加锁方式,用于保证在任意时刻只有一个goroutine能访问共享... 目录一、什么是 Mutex二、为什么需要加锁三、实战案例:并发安全的计数器1. 未加锁示例(存在竞态)

基于Redisson实现分布式系统下的接口限流

《基于Redisson实现分布式系统下的接口限流》在高并发场景下,接口限流是保障系统稳定性的重要手段,本文将介绍利用Redisson结合Redis实现分布式环境下的接口限流,具有一定的参考价值,感兴趣... 目录分布式限流的核心挑战基于 Redisson 的分布式限流设计思路实现步骤引入依赖定义限流注解实现

SpringBoot实现虚拟线程的方案

《SpringBoot实现虚拟线程的方案》Java19引入虚拟线程,本文就来介绍一下SpringBoot实现虚拟线程的方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,... 目录什么是虚拟线程虚拟线程和普通线程的区别SpringBoot使用虚拟线程配置@Async性能对比H

Linux中的HTTPS协议原理分析

《Linux中的HTTPS协议原理分析》文章解释了HTTPS的必要性:HTTP明文传输易被篡改和劫持,HTTPS通过非对称加密协商对称密钥、CA证书认证和混合加密机制,有效防范中间人攻击,保障通信安全... 目录一、什么是加密和解密?二、为什么需要加密?三、常见的加密方式3.1 对称加密3.2非对称加密四、

基于Python实现进阶版PDF合并/拆分工具

《基于Python实现进阶版PDF合并/拆分工具》在数字化时代,PDF文件已成为日常工作和学习中不可或缺的一部分,本文将详细介绍一款简单易用的PDF工具,帮助用户轻松完成PDF文件的合并与拆分操作... 目录工具概述环境准备界面说明合并PDF文件拆分PDF文件高级技巧常见问题完整源代码总结在数字化时代,PD

Python实现Word转PDF全攻略(从入门到实战)

《Python实现Word转PDF全攻略(从入门到实战)》在数字化办公场景中,Word文档的跨平台兼容性始终是个难题,而PDF格式凭借所见即所得的特性,已成为文档分发和归档的标准格式,下面小编就来和大... 目录一、为什么需要python处理Word转PDF?二、主流转换方案对比三、五套实战方案详解方案1:

SpringBoot集成EasyExcel实现百万级别的数据导入导出实践指南

《SpringBoot集成EasyExcel实现百万级别的数据导入导出实践指南》本文将基于开源项目springboot-easyexcel-batch进行解析与扩展,手把手教大家如何在SpringBo... 目录项目结构概览核心依赖百万级导出实战场景核心代码效果百万级导入实战场景监听器和Service(核心

C# async await 异步编程实现机制详解

《C#asyncawait异步编程实现机制详解》async/await是C#5.0引入的语法糖,它基于**状态机(StateMachine)**模式实现,将异步方法转换为编译器生成的状态机类,本... 目录一、async/await 异步编程实现机制1.1 核心概念1.2 编译器转换过程1.3 关键组件解析

setsid 命令工作原理和使用案例介绍

《setsid命令工作原理和使用案例介绍》setsid命令在Linux中创建独立会话,使进程脱离终端运行,适用于守护进程和后台任务,通过重定向输出和确保权限,可有效管理长时间运行的进程,本文给大家介... 目录setsid 命令介绍和使用案例基本介绍基本语法主要特点命令参数使用案例1. 在后台运行命令2.

基于Python Playwright进行前端性能测试的脚本实现

《基于PythonPlaywright进行前端性能测试的脚本实现》在当今Web应用开发中,性能优化是提升用户体验的关键因素之一,本文将介绍如何使用Playwright构建一个自动化性能测试工具,希望... 目录引言工具概述整体架构核心实现解析1. 浏览器初始化2. 性能数据收集3. 资源分析4. 关键性能指