package com.walker.scheduler;

import com.walker.infrastructure.utils.WaitConsoleInput;
import com.walker.scheduler.impl.ForeverScheduler;
import org.junit.Test;

public class TestScheduler {

//    @Test
    public void testRunIdSchedulers(){
        this.createIdScheduler(2, 5000).start();
        this.createIdScheduler(5, 12000).start();
        WaitConsoleInput.waitInput();
        // 控制台输入：exit 退出
        // scheduler.stop();
    }

    private ForeverScheduler createIdScheduler(int id, long timeInterval){
        IdForeverScheduler scheduler = new IdForeverScheduler(id, "任务"+id);
        scheduler.setTimeInterval(timeInterval);        // 内核频率5秒
        scheduler.setWaitSleepTime(60 * 1000);  // 休眠1分钟
        return scheduler;
    }
}