ScheduledExecutorService

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

标签： 任务调度TimerScheduledExecutorSer

2015-08-06 19:07 5704人阅读 评论(2) 收藏 举报

分类：

【定时任务分时器】（3）

作者同类文章X

【java基础】（29）

作者同类文章X

版权声明：本文为博主原创文章，未经博主允许不得转载。如需转载请声明：【转自 http://blog.csdn.net/xiaoxian8023 】

       先前的两篇博文《任务调度(一)——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()方法第一个参数是任务实例，第二个参数是延迟时间，第三个是时间单元。比如调用如下：

[java] view plain copy print?

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

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

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

[java] view plain copy print?

1. /**  
2.  * task1 
3.  *  
4.  * @author arron 
5.  * @date 2015年8月5日 下午2:08:34  
6.  * @version 1.0  
7.  */  
8. public class Task1 implements Runnable{  
9.   
10.     @SuppressWarnings("deprecation")  
11.     public void run() {  
12.         System.out.println("----task1 start--------"+new Date().toLocaleString());  
13.         try {  
14.             Thread.sleep(3000);  
15.         } catch (InterruptedException e) {  
16.             // TODO Auto-generated catch block  
17.             e.printStackTrace();  
18.         }  
19.         System.out.println("----3s later, task1 end--------"+new Date().toLocaleString());  
20.     }  
21.       
22. }  

/** 
 * 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方法：

[java] view plain copy print?

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

	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方法：

[java] view plain copy print?

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

	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的代码。

顶

1

踩

0

 

 

• 上一篇jQuery缓存数据——仿Map
• 下一篇任务调度(四)——ScheduledExecutorService替代Timer，实现多线程任务调度

  相关文章推荐

• • 任务调度——java.util.Timer
• • java的Timer定时任务调度
• • Java并发定时任务调度之Timer和ScheduledExecutorService
• • Timer,ScheduledExecutor ,Quartz,JCronTab任务调度的 Java 实现方法与比较
• • spring任务调度方法之JDK Timer

• • 任务调度(一)——jdk自带的Timer
• • Spring任务调度实战之Timer
• • 用ScheduledExecutorService实现任务调度
• • java.util.Timer 任务调度
• • Java学习之任务调度--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()方法第一个参数是任务实例，第二个参数是延迟时间，第三个是时间单元。比如调用如下：

[java] view plain copy print?

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

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

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

[java] view plain copy print?

1. /**  
2.  * task1 
3.  *  
4.  * @author arron 
5.  * @date 2015年8月5日 下午2:08:34  
6.  * @version 1.0  
7.  */  
8. public class Task1 implements Runnable{  
9.   
10.     @SuppressWarnings("deprecation")  
11.     public void run() {  
12.         System.out.println("----task1 start--------"+new Date().toLocaleString());  
13.         try {  
14.             Thread.sleep(3000);  
15.         } catch (InterruptedException e) {  
16.             // TODO Auto-generated catch block  
17.             e.printStackTrace();  
18.         }  
19.         System.out.println("----3s later, task1 end--------"+new Date().toLocaleString());  
20.     }  
21.       
22. }  

/** 
 * 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方法：

[java] view plain copy print?

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

	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方法：

[java] view plain copy print?

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

	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的代码。