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;
|
}
|
}
|
