ScheduledExecutorService执行周期性或定时任务_schedule(callable callable, long delay, timeuni

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) {

• schedule(task,initDelay):安排所提交的Callable或Runnable任务在initDelay指定的时间后执行。
• scheduleAtFixedRate()：安排所提交的Runnable任务按指定的间隔重复执行
• scheduleWithFixedDelay()：安排所提交的Runnable任务在每次执行完后，等待delay所指定的时间后重复执行。
  代码：ScheduleExecutorService的例子

• import java.util.concurrent.Callable;
  import java.util.concurrent.ExecutionException;
  import java.util.concurrent.Executors;
  import java.util.concurrent.ScheduledExecutorService;
  import java.util.concurrent.ScheduledFuture;
  import java.util.concurrent.TimeUnit;

  public class ScheduledExecutorServiceTest
  {
         public static void main(String[] args) throws InterruptedException,ExecutionException
         {
                //*1
                 ScheduledExecutorService service=Executors.newScheduledThreadPool(2);
                 //*2
                 Runnable task1=new Runnable()
                 {
                      public void run()
                      {
                         System.out.println("Taskrepeating.");
                      }
                 };
                 //*3
                 final ScheduledFuture future1=service.scheduleAtFixedRate(task1,0,1,TimeUnit.SECONDS);
                 //*4
                 ScheduledFuture future2=service.schedule(new Callable()
              {
                      public String call()
                      {
                              future1.cancel(true);
                              return "taskcancelled!";
                      }
                 },10,TimeUnit.SECONDS);
                 System.out.println(future2.get());
       //*5
       service.shutdown();
     }
  }

• 这个例子有两个任务，第一个任务每隔一秒打印一句“Taskrepeating”,第二个任务在5秒钟后取消第一个任务。

  *1:初始化一个ScheduledExecutorService对象，这个对象的线程池大小为2。
  *2:用内函数的方式定义了一个Runnable任务。
  *3:调用所定义的ScheduledExecutorService对象来执行任务，任务每秒执行一次。能重复执行的任务一定是 Runnable类型。注意我们可以用TimeUnit来制定时间单位，这也是Java5.0里新的特征，5.0以前的记时单位是微秒，现在可精确到奈秒。
  *4:调用ScheduledExecutorService对象来执行第二个任务，第二个任务所作的就是在5秒钟后取消第一个任务。

  *5:关闭服务