Java並發之ScheduledExecutorService（schedule、scheduleAtFixedRate、scheduleWithFixedDelay）

package com.thread.test.thread;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.*;
import java.util.concurrent.locks.ReentrantLock;

/**
 * schedule(Runnable command, long delay, TimeUnit unit)
 * @ command: 需要執行的任務
 * @ delay：任務執行需要延遲的時間
 * @ unit：時間單位
 *
 * 一次性執行任務，執行完成結束
 *
 * ScheduledExecutorService：
 * scheduleAtFixedRate（Runnable command, long initialDelay, long period, TimeUnit unit）
 * @ Runnable command: 需要執行的任務
 * @ long initialDelay：第一次執行延遲的時間
 * @ long period：間隔周期
 * @ TimeUnit unit
 *
 * 包含首次延遲的周期性執行任務，第一次執行：delay+period，第二次：delay+2*period,以此類推...
 * 停止：異常停止執行，主動調用停止方法
 * 如果某一個周期執行時間超過設定的period，則后續順延
 *
 * scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
 * @ command: 需要執行的任務
 * @ initialDelay：第一次執行延遲的時間
 * @ delay：周期之間的延遲，間隔
 * @ unit：前兩個參數的單位
 *
 * 周期性執行任務：第一次執行：initialDelay+delay，第二次：initialDelay+2*delay,以此類推...
 * 停止：異常停止執行，主動調用停止方法
 * 不順延
 *
 * Created by windwant on 2016/5/26.
 */
public class MyExecutor {
    public static void main(String[] args) {
        testTimer();
    }

    public static void testTimer(){
        new Timer().schedule(new MyTimerTask(), 2000, 5000);
    }

    public static void testExecutors(){
        MyERunnable mer = new MyERunnable(5);
//        ExecutorService es = Executors.newCachedThreadPool();
//        ExecutorService es = Executors.newFixedThreadPool(2);
        ScheduledExecutorService es = Executors.newScheduledThreadPool(2);
        es.schedule(mer, 10000, TimeUnit.SECONDS.MILLISECONDS);
        es.scheduleAtFixedRate(mer, 2, 10, TimeUnit.SECONDS);
        es.scheduleWithFixedDelay(mer, 1, 5, TimeUnit.SECONDS);
        es.shutdown();
    }
}

class MyERunnable implements Runnable{
    private int num = 0;
    MyERunnable(int num){
        this.num = num;
    }
    public void run() {
        ReentrantLock lock = new ReentrantLock();
        try{
            lock.lock();
            for (int i = 0; i < num; i++) {
                System.out.println("current thread: " + Thread.currentThread().getName() + " num--" + i);
                Thread.sleep(1000);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }
}

class MyTimerTask extends TimerTask{

    @Override
    public void run() {
        System.out.println("timer task");
    }
}

項目地址：https://github.com/windwant/windwant-demo/tree/master/thread-demo