ScheduledExecutorService执行周期性或定时任务

 ScheduledExecutorService扩展了ExecutorService接口，提供时间排程的功能。

 

schedule(Callable<V> callable, long delay, TimeUnit unit)          建立并执行在给定延迟后启用的 ScheduledFuture。

schedule(Runnable command, long delay, TimeUnit unit)          建立并执行在给定延迟后启用的一次性操做。

scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnitunit)          建立并执行一个在给定初始延迟后首次启用的按期操做，后续操做具备给定的周期；也就是将在 initialDelay 后开始执行，而后在initialDelay+period 后执行，接着在 initialDelay + 2 * period 后执行，依此类推。

scheduleWithFixedDelay(Runnable command, long initialDelay, long delay,TimeUnit unit)          建立并执行一个在给定初始延迟后首次启用的按期操做，随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。

 

 

schedule方法被用来延迟指定时间来执行某个指定任务。若是你须要周期性重复执行定时任务可使用scheduleAtFixedRate或者scheduleWithFixedDelay方法，它们不一样的是前者以固定频率执行，后者以相对固定频率执行。

 

 

无论任务执行耗时是否大于间隔时间，scheduleAtFixedRate和scheduleWithFixedDelay都不会致使同一个任务并发地被执行。惟一不一样的是scheduleWithFixedDelay是当前一个任务结束的时刻，开始结算间隔时间，如0秒开始执行第一次任务，任务耗时5秒，任务间隔时间3秒，那么第二次任务执行的时间是在第8秒开始。

 

ScheduledExecutorService的实现类，是ScheduledThreadPoolExecutor。ScheduledThreadPoolExecutor对象包含的线程数量是没有可伸缩性的，只会有固定数量的线程。不过你能够经过其构造函数来设定线程的优先级，来下降定时任务线程的系统占用。

 

 

特别提示：经过ScheduledExecutorService执行的周期任务，若是任务执行过程当中抛出了异常，那么过ScheduledExecutorService就会中止执行任务，且也不会再周期地执行该任务了。因此你若是想保住任务都一直被周期执行，那么catch一切可能的异常。

 

    

package  test;
import  java.text.SimpleDateFormat;
import  java.util.Date;
import  java.util.concurrent.ScheduledThreadPoolExecutor;
import  java.util.concurrent.TimeUnit;

/**
* create at 11-10-14
* @author KETQI
* @category
*/
public  class  TestScheduledThreadPoolExecutor  {
     private  static  SimpleDateFormat  format = new  SimpleDateFormat( "yyyy-MM-dd HH:mm:ss");
     public  static  void  main( String []  args)  {

        //ScheduledExecutorService exec=Executors.newScheduledThreadPool(1);

         ScheduledThreadPoolExecutor  exec  =  new  ScheduledThreadPoolExecutor( 1);
         /**
         *每隔一段时间打印系统时间，互不影响的<br/>
         * 建立并执行一个在给定初始延迟后首次启用的按期操做，后续操做具备给定的周期；<br/>
         * 也就是将在 initialDelay 后开始执行，而后在initialDelay+period 后执行，<br/>
         * 接着在 initialDelay + 2 * period 后执行，依此类推。
         */
         exec . scheduleAtFixedRate( new  Runnable()  {
             public  void  run()  {
                 System . out . println( format . format( new  Date()));
             }
         },  1000 ,  5000 ,  TimeUnit . MILLISECONDS);

         //开始执行后就触发异常,next周期将不会运行
         exec . scheduleAtFixedRate( new  Runnable()  {
             public  void  run()  {
                 System . out . println( "RuntimeException no catch,next time can't run");
                 throw  new  RuntimeException();
             }
         },  1000 ,  5000 ,  TimeUnit . MILLISECONDS);

         //虽然抛出了运行异常,当被拦截了,next周期继续运行
         exec . scheduleAtFixedRate( new  Runnable()  {
             public  void  run()  {
                 try {
                     throw  new  RuntimeException();
                 } catch ( Exception  e ){
                     System . out . println( "RuntimeException catched,can run next");
                 }
             }
         },  1000 ,  5000 ,  TimeUnit . MILLISECONDS);

         /**
         * 建立并执行一个在给定初始延迟后首次启用的按期操做，<br/>
         * 随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。
         */
         exec . scheduleWithFixedDelay( new  Runnable()  {
             public  void  run()  {
                 System . out . println( "scheduleWithFixedDelay:begin," + format . format( new  Date()));
                 try  {
                     Thread . sleep( 2000);
                 }  catch ( InterruptedException  e)  {
                     e . printStackTrace();
                 }
                 System . out . println( "scheduleWithFixedDelay:end," + format . format( new  Date()));
             }
         }, 1000 , 5000 , TimeUnit . MILLISECONDS);

         /**
         * 建立并执行在给定延迟后启用的一次性操做。
         */
         exec . schedule( new  Runnable()  {
             public  void  run()  {
                 System . out . println( "The thread can only run once!");
             }
         }, 5000 , TimeUnit . MILLISECONDS);
     }
}