ScheduledExecutorService

ScheduledExecutorService任务调度(三)——Timer的替代品ScheduledExecutorService简介标签:任务调度TimerScheduledExecutorSer2015-08-0619:075704人阅读评论(2)收藏举报分类:【定时任务分时器】(3)作者同类文章X【java基础】(29)

大家好,又见面了,我是你们的朋友全栈君。

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

标签: 任务调度TimerScheduledExecutorSer

5704人阅读
评论(2)
收藏
举报

ScheduledExecutorService 分类:

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


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

ScheduledExecutorService

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

ScheduledExecutorService

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


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

       ScheduledExecutorService提供了4个方法:

ScheduledExecutorService

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

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

  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方法则是按照固定的延迟去执行任务。

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

  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, 05, 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);
		
	}	

       执行结果如图:

ScheduledExecutorService

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

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


测试scheduleAtFixedRate方法:

  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, 05, 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);
		
	}	

       执行结果如图:

ScheduledExecutorService

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







1

0

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/136932.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • IT需求分析_中国it技术牛人

    IT需求分析_中国it技术牛人  刚刚走过了非比寻常的2006,IT业将迎来一个怎样的2007?尤其是从采购角度来看,2007年有哪些特点和趋势?又有哪些因素将左右2007年的市场需求?  预测2007年的IT市场需求和采购趋势,则一定要先看整体的经济增长速度。  来自法国国家统计及经济研究所(INSEE)的预测,2007年上半年,美国经济放缓将连带着世界经济发展速度的回落。据INSEE的统计,2006年,中国工业…

  • 从零开始的大数据技术学习路线指南:带你轻松成为大数据开发工程师![通俗易懂]

    从零开始的大数据技术学习路线指南:带你轻松成为大数据开发工程师![通俗易懂]之前有不少小伙伴留言和私信我关于大数据学习路线,以及咨询我一些关于有工作经验想转行大数据的问题,只言片语也讲不清。我花了一个月整理了一份我当初学习的大数据学习路线,从最基础的大数据集群搭建开始,希望能帮助到大家。

  • 双机热备 ip地址_防火墙双机热备技术「建议收藏」

    点击上方蓝字关注我吧!双机热备技术双机热备技术产生的原因:传统的组网中,内部用户和外部用户的交互全部通过唯一的一台防火墙,当该防火墙出现故障时,内部网络中所有的主机与外部网络之间的通讯将中断,通讯可靠性无法保证。双机热备技术的出现改变了可靠性难以保证的尴尬状态,通过在网络出口部署两台或多台网关设备,保证了内部网络于外部网络之间的通讯畅通。为了避免传统组网中所形起的单点故障的发生,通常情况…

  • 扯谈网络编程之自己实现ping

    扯谈网络编程之自己实现ping

  • cs模式与bs的区别_BS架构是CS架构的替代品

    cs模式与bs的区别_BS架构是CS架构的替代品C/S:又称Client/Server或客户/服务器模式。客户端需要安装专用的客户端软件。 能充分发挥客户端PC的处理能力,,很多工作可以在客户端处理后再提交给服务器。C/S的主要特点是交互性强、具有安全的存取模式、网络通信量低、响应速度快、利于处理大量数据。但是该结构的程序是针对性开发,变更不够灵活,维护和管理的难度较大。通常只局限于小型局域网,不利于扩展。B/S是Browe

  • scrapy使用代理ip_useragent怎么改

    scrapy使用代理ip_useragent怎么改#使用了fake库fromfake_useragentimportUserAgent#配置headersclassRandomUserAgentMidddlware(object):#随机更换user-agentdef__init__(self,crawler):super(RandomUserAgentMidddlware,self).__init__()self.ua=UserAgent()#.

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号