1.Schedule是什么巫俺？
Java中的Schedule是需要定時執(zhí)行的服務(wù)
生活中的Schedule類似與活動計劃,需要按時執(zhí)行,例如每個工作日,需要8:00點起床恨旱、9:00出發(fā)去上班罢维、12:00吃午飯...
2函荣、生活中唾戚，Schedule組成元素有哪些卿操？
任務(wù)清單列表(每個清單上需要有執(zhí)行時間警检、任務(wù)的具體細(xì)節(jié))
任務(wù)的執(zhí)行者(監(jiān)控任務(wù)清單,關(guān)注每個任務(wù)的執(zhí)行時間,如果當(dāng)前時間有需要執(zhí)行的任務(wù),去執(zhí)行并標(biāo)記執(zhí)行狀態(tài))
3、如何用程序?qū)崿F(xiàn)Schedule害淤？
依據(jù)生活中Schedule的組成元素,程序?qū)崿F(xiàn)則需要:
任務(wù)的載體(具備任務(wù)執(zhí)行時間和任務(wù)詳情)
存儲單元(用于存儲任務(wù)清單列表)
任務(wù)執(zhí)行方(執(zhí)行任務(wù)的線程,需要輪訓(xùn)檢查清單列表中,當(dāng)前時間是否要執(zhí)行的任務(wù))
思考:任務(wù)執(zhí)行方需要不停的輪訓(xùn)檢查當(dāng)前清單列表,若列表中的數(shù)據(jù)量較大時,是否會出現(xiàn)任務(wù)延遲/跳過的問題?
任務(wù)的執(zhí)行方每次依據(jù)當(dāng)前時間與“清單列表”的執(zhí)行時間進(jìn)行比較:
- 若執(zhí)行時間 小于 當(dāng)前時間,任務(wù)執(zhí)行方可將該任務(wù)從清單中直接廢棄/執(zhí)行后再廢棄;
- 若執(zhí)行時間 等于 當(dāng)前時間,任務(wù)執(zhí)行方 需要 執(zhí)行該任務(wù);
- 若執(zhí)行時間 大于 當(dāng)前時間,任務(wù)執(zhí)行方 休息至下一個需執(zhí)行任務(wù);
所以,如果將任務(wù)清單按照執(zhí)行時間后,以從小到大進(jìn)行排序,那么任務(wù)的執(zhí)行方只需要輪訓(xùn)比較檢查清單中的第一個任務(wù)(執(zhí)行時間距當(dāng)前時間最短的任務(wù))即可
4扇雕、優(yōu)化后的Schedule
- 存儲單元使用延遲隊列(其使用了最小堆排序),用于維護(hù)調(diào)整清單中的任務(wù)
關(guān)于延遲隊列:可參考http://www.dockone.io/article/10139
5、動手實戰(zhàn)
列出我們需要實現(xiàn)的內(nèi)容列表：
使用JDK自帶延遲隊列的實現(xiàn)（DelayQueue）
創(chuàng)建任務(wù)類（需要實現(xiàn)Delayed窥摄，因為DelayQueue的元素需強(qiáng)制繼承Delayed類）
開啟一個單線程镶奉，取出并執(zhí)行延遲隊列里的任務(wù)
創(chuàng)建任務(wù)的實例，將實例放入延遲隊列中
運(yùn)行代碼
5.1崭放、創(chuàng)建任務(wù)類DelayTask哨苛，實現(xiàn)Delayed類
import lombok.Data;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
@Data
public class DelayTask implements Delayed {
private long triggerTime;
private Runnable task;
//private boolean cancel;
public DelayTask(long triggerTime, Runnable task) {
this.triggerTime = triggerTime + System.currentTimeMillis();
this.task = task;
}
//獲取任務(wù)剩余執(zhí)行時間
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(triggerTime - System.currentTimeMillis(), TimeUnit.NANOSECONDS);
}
// 比較方法，用于延遲隊列的排序
@Override
public int compareTo(Delayed o) {
DelayTask o2 = (DelayTask) o;
if (this.triggerTime > o2.getTriggerTime()) {
return 1;
}
if (this.triggerTime < o2.getTriggerTime()) {
return -1;
}
return 0;
}
}
5.2币砂、開啟線程建峭，往隊列中取出任務(wù)，并執(zhí)行
import lombok.Data;
import java.util.concurrent.DelayQueue;
/**
* @author lpp
*/
@Data
public class ThreadPool implements Runnable {
private DelayQueue<DelayTask> queue;
public ThreadPool(DelayQueue<DelayTask> queue) {
this.queue = queue;
}
@Override
public void run() {
try {
while (true) {
DelayTask delayTask = queue.take();
Runnable task = delayTask.getTask();
task.run();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
5.3决摧、創(chuàng)建任務(wù)實例亿蒸，放入隊列中，并執(zhí)行代碼
import lombok.Data;
import java.util.concurrent.DelayQueue;
@Data
public class Execute {
private static DelayQueue<DelayTask> queue = new DelayQueue<>();
public static void createSchedule(Runnable runnable, long delayTime) {
queue.offer(new DelayTask(delayTime, runnable));
}
public static void main(String[] args) {
new Thread(new ThreadPool(queue)).start();
createSchedule(() -> System.out.println("XXXX-task1"), 3000);
createSchedule(() -> System.out.println("XXXX-task2"), 1000);
}
}
