扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章给大家分享的是有关大数据开发中定时器有哪些的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。
创新互联建站专注为客户提供全方位的互联网综合服务，包含不限于网站设计制作、成都网站建设、资源网络推广、微信平台小程序开发、资源网络营销、资源企业策划、资源品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联建站为所有大学生创业者提供资源建站搭建服务，24小时服务热线：028-86922220，官方网址：www.cdcxhl.com
何为定时器，说白了就是指定一个延迟时间，到期执行，就像我们早上定的闹铃一样，每天定点提醒我们起床；当然在我们各个系统中也是无处不在，比如定时备份数据，定时拉取文件，定时刷新数据等等；定时器工具也是层出不穷比如Timer，ScheduledExecutorService，Spring Scheduler，HashedWheelTimer(时间轮)，Quartz，Xxl-job/Elastic-job等；本文将对这些定时器工具做个简单介绍和对比，都在哪些场景下使用。
Timer可以说是JDK提供最早的一个定时器了，使用简单，功能也相对来说比较简单；可以指定固定时间后触发，固定时间点触发，固定频率触发；
Timer timer = new Timer();
timer.schedule(new TimerTask() {@Overridepublic void run() {
System.out.println(System.currentTimeMillis() + " === task1");
}
}, 1000, 1000);时间默认为毫秒，表示延迟一秒后执行任务，并且频率为1秒执行任务；Timer内部使用TaskQueue存放任务，使用TimerThread单线程用来执行任务：
private final TaskQueue queue = new TaskQueue();private final TimerThread thread = new TimerThread(queue);
TimerThread内部是一个while(true)循环，不停的从TaskQueue中获取任务执行；当然每次添加到TaskQueue中的任务会进行排序，通过nextExecutionTime来进行排序，这样TimerThread每次都可以获取到最近执行的任务；
Timer有两大缺点：
TimerTask中出现未捕获的异常，影响Timer；
因为是单线程执行某个任务执行时间过长会影响其他认为的精确度；
正因为Timer存在的一些缺点，JDK1.5出现了新的定时器ScheduledExecutorService；
JDK1.5提供了线程池的功能，ScheduledExecutorService是一个接口类，具体实现类是ScheduledThreadPoolExecutor继承于ThreadPoolExecutor；
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);
scheduledExecutorService.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {
System.out.println(Thread.currentThread() + " === " + System.currentTimeMillis() + " === task1");
}
}, 1000, 1000, TimeUnit.MILLISECONDS);比起Timer可以配置多个线程去执行定时任务，同时异常任务并不会中断ScheduledExecutorService，线程池的几个核心配置：
corePoolSize：核心线程数量，如果线程池中的线程少于此数目，则在执行任务时创建，核心线程不会被回收；
maximumPoolSize：允许的最大线程数，当线程数量达到corePoolSize且workQueue队列满了，会创建线程；
keepAliveTime：超过corePoolSize空闲时间；
unit：keepAliveTime的单位；
workQueue：当线程超过corePoolSize，新的任务会被加入到队列中等待；
threadFactory：创建线程的工厂类；
handler：线程池拒绝策略，包括：AbortPolicy，DiscardPolicy，DiscardOldestPolicy，CallerRunsPolicy策略，当然也可以自己扩展；
ScheduledExecutorService中添加的任务会被包装成一个ScheduledFutureTask类，同时将任务放入DelayedWorkQueue队列中是一个BlockingQueue；类似Timer也会根据加入任务触发时间的先后进行排序，然后线程池中的Worker会到Queue中获取任务执行；
Spring提供了xml和注解方式来配置调度任务，如下面xml配置：