ScheduledExecutorService 接口[通俗易懂]

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

newScheduledThreadPool() 或者newSingleThreadScheduled-Executor()方法：延迟执行、周期性执行的执行器

           如果想在某一段时间之后执行线程操作，或者周期性地重复执行线程操作，则可以使用工厂类Executors的newScheduledThreadPool()方法或者 newSingleThreadScheduled-Executor()方法。
           newScheduledThreadPool()方法使用给定数目的线程来调度执行任务，而newSingleThreadScheduledExecutor()方法在一个单独的线程中调度任务。
           这两个方法都将返回一个ScheduledExecutorService线程池对象。

       ScheduledExecutorService接口

       ScheduledExecutorService接口从ExecutorService接口继承而来，可用于在给定的延迟后运行的某个任务，或者周期性的执行某个任务。
           schedule()方法用于创建并执行给定的延迟的任务，返回的ScheduledFuture对象可以取消执行，或检查执行状态。scheduleAtFixedRate 和scheduleWithFixedDelay用于创建并执行一个周期性或者
           固定延迟任务，直到任务取消。
           在schedule()方法中，延迟时间一般大于0,但也允许取值为0或者负数(非周期性执行)，在这种情况下，认为是立刻执行。
           TimeUnit 用于指明时间单位，时间都是相对的时间，而不是绝对的时间。例如，在某一个日期之后运行，则可以使用下面的语句。
           scheduled(commad,date.getTime() -System.currentTimeMills,TimeUnit.MILLISECONDS)

       ScheduledFuture接口
           ScheduledExecutorService接口的4个方法都将返回ScheduledFuture对象，ScheduledFuture也是一个接口，他从Delay和Future接口继承而来，表示一个延迟的、结果可接受的操作。
           该接口的getDelay方法用于获得延迟时间，get()方法用于获得操作结果，cancel()方法用于取消一个任务。

           demo 示例：

           监控一个设备的工作温度，当温度超过10°C后，每隔1s发出一次警告，如果连续发出10报警后，仍没有处理，则停止设备运行。

           分析：设置两个线程，一个线程表示设备运行。一个线程监视设备运行，采用ScheduleAtFixedRate()方法来调度，当设备警告10次，采用取消cancel()或者shutdown()方法关闭设备。

           //设备线程类
           public class Machine implements Runnable{

               int temperature;
               Machine(int temperature){

                   this.temperature = temperature;
               }
               public void run(){

                   perform();
                   temperature++;
                   System.out.println(“机器的工作温度在升高，当前的温度：”+temperature);
               }
               private void perform(){

                   int temp = (int)(Math.random()*Integer.MAX_VALUE);
                   int sum = 0;
                   for(int i=0;i<temp;i++){

                       sum += i;
                   }
               }
               private int getTemperature(){

                   return temperature;
               }
           }

           //监控设备线程类
           public class Monitor implements Runnable{

               Machine machine;
               ScheduledExecutorService scheduler;
               static int n = 0;

               Monitor(Machine machine,ScheduledExecutorService scheduler){

                   this.machine = machine;
                   this.scheduler = scheduler;
               }
               public void run(){

                   if(machine.temperature>=10){

                       System.out.println(“警告！机器温度过高。”);
                       n++;
                   }
                   if(n>10){

                       System.out.println(“提醒次数限制已到，禁止任务”);
                       scheduler.shutdown();
                   }
               }
           }

           //测试启动类
           public class Index{

               public static void main(String[] args){

                   ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
                   Machine machine = new Machine(0);
                   Monitor monitor = new Monitor(machine,scheduler);
                   scheduler.scheduleAtFixedRate(machine,1,2,TimeUnit.SECONDS);
                   scheduler.scheduleAtFixedRate(monitor,0,1,TimeUnit.SECONDS);
               }
           }

运行结果：

机器的工作温度在升高，当前的温度：1
机器的工作温度在升高，当前的温度：2
机器的工作温度在升高，当前的温度：3
机器的工作温度在升高，当前的温度：4
机器的工作温度在升高，当前的温度：5
机器的工作温度在升高，当前的温度：6
机器的工作温度在升高，当前的温度：7
机器的工作温度在升高，当前的温度：8
机器的工作温度在升高，当前的温度：9
机器的工作温度在升高，当前的温度：10
警告！机器温度过高。
警告！机器温度过高。
机器的工作温度在升高，当前的温度：11
警告！机器温度过高。
警告！机器温度过高。
机器的工作温度在升高，当前的温度：12
警告！机器温度过高。
警告！机器温度过高。
机器的工作温度在升高，当前的温度：13
警告！机器温度过高。
警告！机器温度过高。
机器的工作温度在升高，当前的温度：14
警告！机器温度过高。
警告！机器温度过高。
机器的工作温度在升高，当前的温度：15
警告！机器温度过高。
提醒次数限制已到，禁止任务