任务调度(三)——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的代码。


目录
相关文章
|
5月前
|
存储 JavaScript 前端开发
RxJS中的调度器(Scheduler)机制
RxJS中的调度器(Scheduler)机制
53 0
|
5月前
|
消息中间件 安全 Java
一起来探究@Schedule定时任务在分布式产生的问题
一起来探究@Schedule定时任务在分布式产生的问题
268 0
|
8月前
|
调度
RxSwift调度器 - Schedulers
RxSwift调度器 - Schedulers
62 1
|
Java API 调度
ThreadPoolTaskScheduler轻量级多线程定时任务框架
面对一些小的功能需求点,如果需要非常灵活的进行处理定时任务处理,但是又因为你的需求需要使用到页面进行定时任务配置,显然使用Spring注解定时任务,无法满足你,这时你想到了xxl-job 或者 quezy等定时任务框架,但是过于繁琐,可能成本较大。那么本文将要解决你的问题
1530 0
|
Java 调度
ScheduledExecutorService:多线程任务调度
ScheduledExecutorService:多线程任务调度
680 0
ScheduledExecutorService:多线程任务调度
|
存储 Java API
调度线程池ScheduledThreadPoolExecutor源码解析
调度线程池ScheduledThreadPoolExecutor源码解析
121 0
调度线程池ScheduledThreadPoolExecutor源码解析
|
Python
Python编程:定时任务apscheduler框架
Python编程:定时任务apscheduler框架
234 0
Python编程:定时任务apscheduler框架
|
Java Maven
仿写@ScheduleLock 定时任务
最近公司在搞分布式的定时任务, 怎么满足分布式的定时任务锁。 我看了大量的开源的代码。 https://github.com/lukas-krecan/ShedLock 感觉老外写的非常的不错。
仿写@ScheduleLock 定时任务
|
数据可视化 Linux Python
Schedule | 轻量化的定时任务模块
Schedule | 轻量化的定时任务模块
327 0
|
Java 调度
高并发之——ScheduledThreadPoolExecutor与Timer的区别和简单示例
DK 1.5开始提供ScheduledThreadPoolExecutor类,ScheduledThreadPoolExecutor类继承ThreadPoolExecutor类重用线程池实现了任务的周期性调度功能。在JDK 1.5之前,实现任务的周期性调度主要使用的是Timer类和TimerTask类。本文,就简单介绍下ScheduledThreadPoolExecutor类与Timer类的区别,ScheduledThreadPoolExecutor类相比于Timer类来说,究竟有哪些优势,以及二者分别实现任务调度的简单示例。
172 0