package com.thread.test.ThreadPool;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

public class ScheduledExecutorServiceDemo {

    public static void main(String[] args) {

        ScheduledExecutorService ses = Executors.newScheduledThreadPool(10);

        // scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)任务调度的频率是一定的

        // 任务开始于给定的初始延时时间initialDelay，后续任务将会按照给定的周期period进行：后续第一个任务将会在initialDelay+period时执行，

        // 后续第二个任务将在initialDelay+2*period时执行，以此类推

        // scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)

        // 任务开始于给定的初始延时时间initialDelay，后续任务将会按照给定的延时delay进行，即上一个任务的结束时间到下一个任务的开始时间的时间差

        ses.scheduleAtFixedRate(new Runnable() {

            public void run() {

                try {

                    Thread.sleep(1000);// 模拟任务的执行时间是1s

                    // 如果调度周期是2s，任务的执行时间是8s，那么任务的执行周期会变成8s

                    // 如果调度周期是2s，任务的执行时间是1s，那么任务的执行周期就是设置的2s

                    System.out.println(System.currentTimeMillis() / 1000 + "s");

                } catch (InterruptedException e) {

                    e.printStackTrace();

                    // 如果任务遇到异常，那么后续的所有子任务都会停止调度，因此，必须保证异常被及时处理，为周期性任务的稳定调度提供条件

                }

            }

        }, 0, 2, TimeUnit.SECONDS);

        // 任务开始于给定的初始延时时间--0s，后续任务将会按照给定的周期--2s进行：后续第一个任务将会在initialDelay+period--2s时执行，

        // 后续第二个任务将在initialDelay+2*period--4s时执行，以此类推

    }

}

1516775766s

1516775768s

1516775770s

1516775772s

1516775774s

1516775776s

1516775778s

.......

...

.

1516775824s

1516775827s

1516775830s

1516775833s

1516775836s

1516775839s

......

...

.