使用ScheduledExecutorService实现Timer

大家都说Timer不太好用,经常会遇到:如果前边的一个任务比较慢,超出了period,此时timer的下一次轮询也不会延迟。

同事说ScheduleExecutorService可以避免该问题,我写个例子测试下:

package com.dx.testparallel;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;;

public class TestTimer {
    public static void main(String[] args){
        ScheduledExecutorService scheduledExecutorService=Executors.newScheduledThreadPool(1);
        //Creates and executes a periodic action that becomes enabled
        //first after the given initial delay, and subsequently with the
        //given period; that is executions will commence after
        //initialDelay then initialDelay+period, then initialDelay + 2 *
        //period, and so on. If any execution of the task encounters an
        //exception, subsequent executions are suppressed.
        //Otherwise, the task will only terminate via cancellation or
        //termination of the executor. If any execution of this task
        //takes longer than its period, then subsequent executions may
        //start late, but will not concurrently execute.
        scheduledExecutorService.scheduleAtFixedRate(new TheTask(), 0,1000, TimeUnit.MILLISECONDS);
    }
}
package com.dx.testparallel;

import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.UUID;

import javax.lang.model.element.VariableElement;

public class TheTask implements Runnable{
    @Override
    public void run() {
          Timestamp ts = new Timestamp(System.currentTimeMillis());
          UUID uuid = UUID.randomUUID();
          System.out.println("task"+uuid+" start:"+ts.toString());

//          long num=0;
//          for(int a=0;a<100000;a++){
//              for(int i=0;i<1000000;i++){
//                  for(int j=0;j<1000000;j++){
//                      num= a*i*j;
//                  }
//              }
//          }
          try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

          ts = new Timestamp(System.currentTimeMillis());
          System.out.println("task"+uuid+" end:"+ts.toString());
    }
}

测试结果:为什么每次间隔时间是2s,而不是1s.

task418d088e-3288-4736-b40a-f3c4f496e2a2 start:2016-09-07 00:49:03.699
task418d088e-3288-4736-b40a-f3c4f496e2a2 end:2016-09-07 00:49:05.836
task741d2176-dbef-4f12-a73e-13a04ed5eb18 start:2016-09-07 00:49:05.836
task741d2176-dbef-4f12-a73e-13a04ed5eb18 end:2016-09-07 00:49:07.836
task96ebb6ca-c99b-482e-b608-bd560e89c7eb start:2016-09-07 00:49:07.836
task96ebb6ca-c99b-482e-b608-bd560e89c7eb end:2016-09-07 00:49:09.837
task1ce9f4bb-dd9e-4510-a697-73daef02fe6b start:2016-09-07 00:49:09.837
task1ce9f4bb-dd9e-4510-a697-73daef02fe6b end:2016-09-07 00:49:11.837
task0386a855-3e85-4d06-9d91-24abde228731 start:2016-09-07 00:49:11.837
task0386a855-3e85-4d06-9d91-24abde228731 end:2016-09-07 00:49:13.838
task886fe541-92d1-49bc-b5bd-2c425cf773ba start:2016-09-07 00:49:13.838
task886fe541-92d1-49bc-b5bd-2c425cf773ba end:2016-09-07 00:49:15.838
task460137d1-7daf-419b-b0d5-87f31833176c start:2016-09-07 00:49:15.838
task460137d1-7daf-419b-b0d5-87f31833176c end:2016-09-07 00:49:17.838
taskce78bffb-8151-46e8-81d9-57b01e9294a2 start:2016-09-07 00:49:17.838
taskce78bffb-8151-46e8-81d9-57b01e9294a2 end:2016-09-07 00:49:19.838
task1fad4b4f-4143-4098-943a-c894ad96ae58 start:2016-09-07 00:49:19.838
task1fad4b4f-4143-4098-943a-c894ad96ae58 end:2016-09-07 00:49:21.838
taskc5de2fab-0688-4410-9408-b0990cc76223 start:2016-09-07 00:49:21.838
taskc5de2fab-0688-4410-9408-b0990cc76223 end:2016-09-07 00:49:23.838
task7dccb95b-6088-4a5d-a2e0-edb4381f7d0c start:2016-09-07 00:49:23.838
task7dccb95b-6088-4a5d-a2e0-edb4381f7d0c end:2016-09-07 00:49:25.838
taskc05908b5-1bb2-496a-9ddc-c3939d783f2c start:2016-09-07 00:49:25.838
taskc05908b5-1bb2-496a-9ddc-c3939d783f2c end:2016-09-07 00:49:27.839
task251c4102-f214-4eb9-9e13-7ca7f2eb3362 start:2016-09-07 00:49:27.839
task251c4102-f214-4eb9-9e13-7ca7f2eb3362 end:2016-09-07 00:49:29.839
task645f6f0f-9d11-4545-be12-1feab67a6b06 start:2016-09-07 00:49:29.839
task645f6f0f-9d11-4545-be12-1feab67a6b06 end:2016-09-07 00:49:31.84
task82da54a5-6620-46f4-a840-10633555d2e8 start:2016-09-07 00:49:31.84
task82da54a5-6620-46f4-a840-10633555d2e8 end:2016-09-07 00:49:33.84
taskb33558c1-cb84-4724-85af-ac8060b169a0 start:2016-09-07 00:49:33.84
时间: 2024-10-19 22:32:53

使用ScheduledExecutorService实现Timer的相关文章

任务调度(四)——ScheduledExecutorService替代Timer,实现多线程任务调度

上篇博文<任务调度(三)--Timer的替代品ScheduledExecutorService简介>已经对ScheduledExecutorService做了简单介绍,其实使用ScheduledExecutorService来替代Timer也是迫不得已的事情.主要原因如下: Timer不支持多线程,所有挂在Timer下的任务都是单线程的,任务只能串行执行,如果其中一个任务执行时间过长,会影响到其他任务的执行,然后就可能会有各种接踵而来的问题. Timer的线程不捕获异常,TimerTask如果

详解java定时任务---Timer篇

一.简介      在java的jdk中提供了Timer.TimerTask两个类来做定时任务. Timer是一种定时器工具,用来在一个后台线程计划执行指定任务,而TimerTask一个抽象类,它的子类代表一个可以被Timer计划的任务.--------------------- Timer类      在工具类Timer中,提供了四个构造方法,每个构造方法都启动了计时器线程,同时Timer类可以保证多个线程可以共享单个Timer对象而无需进行外部同步,所以Timer类是线程安全的.但是由于每一

Java四种线程池newCachedThreadPool,newFixedThreadPool,newScheduledThreadPool,newSingleThreadExecutor

介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? Java new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub } }).start(); 1 2 3 4 5 6 7 new Thread(new

Java四种线程池

Java四种线程池newCachedThreadPool,newFixedThreadPool,newScheduledThreadPool,newSingleThreadExecutor 时间:2015-10-20 22:37:40      阅读:8762      评论:0      收藏:0      [点我收藏+] 介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行一个异

具体解释java定时任务

在我们编程过程中假设须要运行一些简单的定时任务,无须做复杂的控制.我们能够考虑使用JDK中的Timer定时任务来实现. 以下LZ就其原理.实例以及Timer缺陷三个方面来解析java Timer定时器. 一.简单介绍 在java中一个完整定时任务须要由Timer.TimerTask两个类来配合完毕. API中是这样定义他们的.Timer:一种工具.线程用其安排以后在后台线程中运行的任务.可安排任务运行一次,或者定期反复运行.由TimerTask:Timer 安排为一次运行或反复运行的任务.我们能

Java(Android)线程池

介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行一个异步任务你还只是如下new Thread吗? Java new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub } }).start(); 那你就out太多了,new Thread的弊端如下: a.

java线程池

1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? 1 new Thread(new Runnable() { 2 3 @Override 4 public void run() { 5 // TODO Auto-generated method stub 6 } 7 }).start(); 那你就out太多了,new Thread的弊端如下: a. 每次new Thread新建对象性能差. b. 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过

Java(Android)线程池 总结

一种是使用Executors工厂生产线程池:另一种是直接使用ThreadPoolExecutor自定义. Executors工厂生产线程池 Java(Android)线程池 Trinea 介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行一个异步任务你还只是如下new Thread吗? Java 1 2 3 4 5 6 7 newThread(newRunnable(){ @Ove

线程池使用

1.new Thread的弊端 a. 每次new Thread新建对象性能差. b. 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过多系统资源导致死机或oom.   c. 缺乏更多功能,如定时执行.定期执行.线程中断.相比new Thread,Java提供的四种线程池的好处在于:  a. 重用存在的线程,减少对象创建.消亡的开销,性能佳.  b. 可有效控制最大并发线程数,提高系统资源的使用率,同时避免过多资源竞争,避免堵塞.  c. 提供定时执行.定期执行.单线程.并发数控制