news 2026/6/9 12:26:07

ScheduledExecutorService 行为观察 Demo(可直接跑)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
ScheduledExecutorService 行为观察 Demo(可直接跑)

这个 Demo 主要做两件事:

  • 建一个ScheduledThreadPoolExecutor(2),看看 2 线程时任务分配情况
  • 对比scheduleAtFixedRatescheduleWithFixedDelay的行为
  • 每个任务打印:当前时间、线程名、第几次执行

你可以新建一个ScheduledDemo.java直接运行:

import java.time.LocalTime; import java.time.format.DateTimeFormatter; import java.util.concurrent.*; public class ScheduledDemo { private static final DateTimeFormatter F = DateTimeFormatter.ofPattern("HH:mm:ss.SSS"); private static String now() { return LocalTime.now().format(F); } public static void main(String[] args) throws InterruptedException { // 2 个线程的定时线程池 ScheduledExecutorService ses = Executors.newScheduledThreadPool(2, new ThreadFactory() { private final ThreadFactory delegate = Executors.defaultThreadFactory(); private int idx = 1; @Override public Thread newThread(Runnable r) { Thread t = delegate.newThread(r); t.setName("sched-worker-" + (idx++)); return t; } }); System.out.println("[" + now() + "] main start"); // FixedRate 任务:理论上每 5 秒一次,task 执行 3 秒 Runnable fixedRateTask = new Runnable() { private int count = 0; @Override public void run() { String thread = Thread.currentThread().getName(); int curr = ++count; System.out.println("[" + now() + "] [FixedRate] 第 " + curr + " 次执行,线程 = " + thread); try { // 模拟执行 3 秒 TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { System.out.println("[" + now() + "] [FixedRate] 被中断,线程 = " + thread); Thread.currentThread().interrupt(); } } }; // FixedDelay 任务:每次执行完后,延迟 5 秒再执行,task 执行 3 秒 Runnable fixedDelayTask = new Runnable() { private int count = 0; @Override public void run() { String thread = Thread.currentThread().getName(); int curr = ++count; System.out.println("[" + now() + "] [FixedDelay] 第 " + curr + " 次执行,线程 = " + thread); try { // 模拟执行 3 秒 TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { System.out.println("[" + now() + "] [FixedDelay] 被中断,线程 = " + thread); Thread.currentThread().interrupt(); } } }; // 0 延时,之后每 5 秒触发一次(FixedRate) ses.scheduleAtFixedRate(fixedRateTask, 0, 5, TimeUnit.SECONDS); // 0 延时,执行完成之后等待 5 秒(FixedDelay) ses.scheduleWithFixedDelay(fixedDelayTask, 0, 5, TimeUnit.SECONDS); // 让 Demo 跑 40 秒,观察日志 TimeUnit.SECONDS.sleep(40); System.out.println("[" + now() + "] main shutdown"); ses.shutdown(); } }

你跑一下,会看到类似(大概意思):

  • FixedRate:如果 3s < 5s,就基本是每 5 秒一轮

  • FixedDelay:永远是 “执行 3 秒 + 延迟 5 秒 = 8 秒一轮”

  • 线程名会在sched-worker-1/sched-worker-2之间分配,你能清楚看到:
    同一个周期任务不会重叠执行,但是轮次之间可能换线程。

如果你想再观察“执行时间 > 间隔”的情况,把sleep(3)改成sleep(7),日志会更有意思:

  • FixedRate:会出现“补课式”紧接执行

  • FixedDelay:节奏变慢,但依旧“执行完 + 延时”。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/5/27 2:12:26

32、合并用户数据库与拼写检查:Unix 工具的实用应用

合并用户数据库与拼写检查:Unix 工具的实用应用 合并用户数据库 在处理多系统用户数据时,常常需要合并不同计算机的密码文件,以实现文件共享。下面将详细介绍合并用户数据库的相关操作及注意事项。 生成最终密码文件 首先需要将三个 unique 文件合并生成最终的密码文件…

作者头像 李华
网站建设 2026/6/8 12:06:23

40、深入了解Shell:下载、版本与初始化指南

深入了解Shell:下载、版本与初始化指南 1. 下载bash和ksh93源代码 在开始介绍之前,先了解一些逻辑表达式的示例,比如 $((3 > 2)) 的值为1, $(( (3 > 2) || (4 <= 1) )) 的值也为1,因为两个子表达式中至少有一个为真。 1.1 下载bash bash可以从自由软件基…

作者头像 李华
网站建设 2026/6/6 14:59:41

41、深入了解Shell的可移植性、启动终止及安全脚本编写

深入了解Shell的可移植性、启动终止及安全脚本编写 1. Shell会话与Z-Shell启动终止 1.1 Shell会话类型 Shell会话分为交互式和非交互式两种。交互式会话仅调用单个文件,例如: $ bash Start an interactive session DEBUG: This is /home/bones/.bashrc $ exit Terminate…

作者头像 李华
网站建设 2026/6/8 11:28:19

压力测试瓶颈定位分析法:从现象到根因的系统性解决方案

压力测试中的瓶颈挑战 在软件开发生命周期中&#xff0c;压力测试是确保系统在高并发、高负载环境下稳定性的关键环节。然而&#xff0c;许多测试团队常面临瓶颈定位模糊、响应时间骤增或资源耗尽等问题&#xff0c;导致测试效果大打折扣。本文针对软件测试从业者&#xff0c;…

作者头像 李华
网站建设 2026/6/9 6:42:10

46、Unix 文件系统深入解析

Unix 文件系统深入解析 1. 访问控制列表(ACLs) 部分 Unix 系统支持访问控制列表(ACLs)这一特性,它能够对访问权限进行更精细的控制,可给特定用户或用户组分配非默认的权限。然而,不同系统用于设置和显示 ACLs 的工具差异很大,这使得 ACLs 在异构环境中用处不大,情况…

作者头像 李华