任务调度(三)——Timer的替代品ScheduledExecutorService简介

简介:        先前的两篇博文《任务调度(一)——jdk自带的Timer》和《任务调度(二)——jdk自带的Timer 动态修改任务执行计划》中,简单介绍了一下Timer,可以实现几本的功能,但是在多线程方面却略显不足。

       先前的两篇博文《任务调度(一)——jdk自带的Timer》和《任务调度(二)——jdk自带的Timer 动态修改任务执行计划》中,简单介绍了一下Timer,可以实现几本的功能,但是在多线程方面却略显不足。


       根据Timer源码,可以看到Timer是单线程的。所以task都是串行执行。假如其中一个task执行需要很长的时间,那其他的task只能干巴巴的等着。怎么办!


      现在就遇到了这样的问题。总不能因为这个小小的问题就去换别的任务调度框架吧,还是想用最简单的方案去解决一下。所以ScheduledExecutorService就被我选中了。这个是怎么找到的?1.网上搜,2.好好的看Timer类的注释:


       翻译一下:java5.0引入了java.util.concurrent包,其中java.util.concurrent.scheduledthreadpoolexecutor就是在并发实用工具其中之一。scheduledthreadpoolexecutor是一个可以重复执行任务的线程池,并且可以指定任务的间隔和延迟时间。它作为比Timer/TimerTask更加通用的替代品。因为它允许多个服务线程,接受不同的时间单位,且不需要继承TimeTask(仅仅需要实现Runnable接口)。配置ScheduledThreadPoolExecutor为单线程,则与使用Timer等效。


       ScheduledThreadPoolExecutor实现了ScheduledExecutorService接口,所以标题中使用了接口的名字。

       ScheduledExecutorService提供了4个方法:


       其中第二个方法比较特殊一点,第一个参数是Callable,别的都是Runnable,二者的区别不再这篇博文的讨论范围之内。就此略过。说一些其他三个方法。

       schedule()方法第一个参数是任务实例,第二个参数是延迟时间,第三个是时间单元。比如调用如下:

	ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);
	pool.schedule(task1, 5, TimeUnit.SECONDS);//延迟5s后,执行且只执行一次task1

       scheduleAtFixedRate()和scheduleWithFixedDelay方法参数是一样的。第一个参数是任务实例,第二个参数是延迟时间,第三个是间隔时间,第四个是时间单元。这两个方法的不同之处在方法名也能看得出来:scheduleAtFixedRate方法是按照固定频率去执行任务的。而scheduleWithFixedDelay方法则是按照固定的延迟去执行任务。

/** 
 * task1
 * 
 * @author arron
 * @date 2015年8月5日 下午2:08:34 
 * @version 1.0 
 */
public class Task1 implements Runnable{

	@SuppressWarnings("deprecation")
	public void run() {
		System.out.println("----task1 start--------"+new Date().toLocaleString());
		try {
			Thread.sleep(3000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("----3s later, task1 end--------"+new Date().toLocaleString());
	}
	
}
测试scheduleAtFixedRate方法:
	public static void main(String[] args) {
		
		ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
		
		Task1 t1 = new Task1();
		//立即执行t1,3s后任务结束,再等待2s(间隔时间-消耗时间),如果有空余线程时,再次执行该任务
		pool.scheduleAtFixedRate(t1, 0, 5, TimeUnit.SECONDS);
		
	}	
       执行结果如图:

       task1第二次执行的前提是,当前有空余的线程。

       执行的开始时间则是上一次结束时间+(间隔时间-任务消耗的时间)。加入这个差值小于0,即间隔时间小于任务消耗的时间,那就不会再等待,会立即执行(当然得满足前提)。


测试scheduleAtFixedRate方法:

	public static void main(String[] args) {
		
		ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
		
		Task1 t1 = new Task1();
		//立即执行t1,3s后任务结束,再等待5s(间隔时间-消耗时间),如果有空余线程时,再次执行该任务
		pool.scheduleWithFixedDelay(t1, 0, 5, TimeUnit.SECONDS);
		
	}	
       执行结果如图:


       就简单介绍到这里,下篇将会分享替换Timer的代码。


目录
相关文章
|
消息中间件 存储 缓存
3分钟白话RocketMQ系列—— 如何消费消息
3分钟白话RocketMQ系列—— 如何消费消息
1191 0
|
7月前
|
SQL 关系型数据库 MySQL
milvus-use教程 python
本项目参考vanna项目,获取数据库元数据和问题SQL对,存入Milvus向量数据库,并进行相似性检索。采用m3e-large嵌入模型,通过DatabaseManager类实现数据库连接持久化,MilvusVectorStore类封装了Milvus操作方法,如创建集合、添加数据和查询。项目提供init_collections、delete_collections等文件用于初始化、删除和管理集合。所用Milvus版本较新,API与vanna项目不兼容。 [项目地址](https://gitee.com/alpbeta/milvus-use)
|
算法 Java Go
Go vs Java:内存管理与垃圾回收机制对比
对比了Go和Java的内存管理与垃圾回收机制。Java依赖JVM自动管理内存,使用堆栈内存并采用多种垃圾回收算法,如标记-清除和分代收集。Go则提供更多的手动控制,内存分配与释放由分配器和垃圾回收器协同完成,使用三色标记算法并发回收。示例展示了Java中对象自动创建和销毁,而Go中开发者需注意内存泄漏。选择语言应根据项目需求和技术栈来决定。
|
11月前
|
前端开发 JavaScript UED
什么是 CSS Modules ?我们为什么需要它们
CSS Modules 是一种将 CSS 与模块系统结合的技术,通过局部作用域和模块隔离,解决了传统 CSS 全局样式污染的问题。本文介绍了 CSS Modules 的基本概念、主要特点及其优势,包括自动生成唯一类名、提高代码可维护性和可读性、支持动态样式和主题切换等,并提供了 React 中的使用示例。
506 6
|
Prometheus 监控 Cloud Native
Web服务器的日志分析与监控
【8月更文第28天】Web服务器日志提供了关于服务器活动的重要信息,包括访问记录、错误报告以及性能数据。有效地分析这些日志可以帮助我们了解用户行为、诊断问题、优化网站性能,并确保服务的高可用性。本文将介绍如何使用日志分析和实时监控工具来监测Web服务器的状态和性能指标,并提供具体的代码示例。
995 0
mo-quarter-picker:基于 Vue2 和 ElementUI 的季度范围选择器
mo-quarter-picker:基于 Vue2 和 ElementUI 的季度范围选择器
1012 0
mo-quarter-picker:基于 Vue2 和 ElementUI 的季度范围选择器
|
Web App开发 人工智能 小程序
通义听悟再升级,上线自动提取ppt等三大实用功能
通义听悟再升级,上线自动提取ppt等三大实用功能
962 1
|
监控 Java API
干货:教你如何监控 Java 线程池运行状态
之前写过一篇 Java 线程池的使用介绍文章《线程池全面解析》,全面介绍了什么是线程池、线程池核心类、线程池工作流程、线程池分类、拒绝策略、及如何提交与关闭线程池等。
6070 0
|
域名解析 弹性计算 网络协议
新手阿里云服务器操作指南(图文教程)
新手阿里云服务器操作指南(图文教程)阿里云轻量应用服务器怎么使用?阿里云轻量应用服务器使用教程:轻量应用服务器购买、重置密码、远程连接、宝塔面板的Web环境搭建、WordPress网站程序安装到网站上线,阿里云服务器网分享轻量应用服务器从购买、配置建站环境、轻量服务器应用服务器远程连接、开端口到网站上线全流程
1647 1
|
SQL 分布式计算 资源调度
Spark - Illegal pattern component: XXX 与org.apache.commons.lang3.time.FastDateFormat incompatible
使用 sparkSession 读文件时出现java.lang.IllegalArgumentException: Illegal pattern component: XXX 报错,解决后又出现java.io.InvalidClassException: org.apache.commons.lang3.time.FastDateFormat; local class incompatible: stream classdesc serialVersionUID = 2,下面解决一下。...
342 0
Spark - Illegal pattern component: XXX 与org.apache.commons.lang3.time.FastDateFormat incompatible