From 52ade857676300e9d3325cfa7797802f9e41ad44 Mon Sep 17 00:00:00 2001 From: lxyer <237809796@qq.com> Date: Thu, 6 Dec 2018 20:02:42 +0800 Subject: [PATCH] . --- src/main/java/com/lxyer/timer/AbstractTask.java | 15 +++++++++++++++ src/main/java/com/lxyer/timer/Task.java | 12 ++++++++++++ src/main/java/com/lxyer/timer/TimerExecutor.java | 1 + src/test/java/com/lxyer/timer/TaskImpl.java | 5 +++++ 4 files changed, 33 insertions(+) diff --git a/src/main/java/com/lxyer/timer/AbstractTask.java b/src/main/java/com/lxyer/timer/AbstractTask.java index 725abb6..9f39998 100644 --- a/src/main/java/com/lxyer/timer/AbstractTask.java +++ b/src/main/java/com/lxyer/timer/AbstractTask.java @@ -12,6 +12,8 @@ public abstract class AbstractTask implements Task { protected String name; private long theTime; private Scheduled scheduled; + private boolean isComplete; + private long startTime = System.currentTimeMillis(); public AbstractTask(String name, Scheduled scheduled) { this.name = name; @@ -45,5 +47,18 @@ public abstract class AbstractTask implements Task { this.theTime = next.toInstant(ZoneOffset.of("+8")).toEpochMilli(); return theTime; } + + @Override + public boolean isComplete() { + return isComplete; + } + + public void setComplete(boolean complete) { + isComplete = complete; + } + + public long startTime() { + return startTime; + } } diff --git a/src/main/java/com/lxyer/timer/Task.java b/src/main/java/com/lxyer/timer/Task.java index d20fe60..8607a8f 100644 --- a/src/main/java/com/lxyer/timer/Task.java +++ b/src/main/java/com/lxyer/timer/Task.java @@ -38,4 +38,16 @@ public interface Task extends Runnable{ * 执行任务 */ void run(); + + /** + * 是否完成 + * @return + */ + boolean isComplete(); + + /** + * 开始时间(创建时间) + * @return + */ + long startTime(); } diff --git a/src/main/java/com/lxyer/timer/TimerExecutor.java b/src/main/java/com/lxyer/timer/TimerExecutor.java index 124d863..3f07e67 100644 --- a/src/main/java/com/lxyer/timer/TimerExecutor.java +++ b/src/main/java/com/lxyer/timer/TimerExecutor.java @@ -44,6 +44,7 @@ public class TimerExecutor { e.printStackTrace(); } + //执行调度 executor.execute(take); add(take, true); }catch (Exception e){ diff --git a/src/test/java/com/lxyer/timer/TaskImpl.java b/src/test/java/com/lxyer/timer/TaskImpl.java index 549692f..336517e 100644 --- a/src/test/java/com/lxyer/timer/TaskImpl.java +++ b/src/test/java/com/lxyer/timer/TaskImpl.java @@ -22,4 +22,9 @@ public class TaskImpl extends AbstractTask { } System.out.printf("执行任务:%s now:%s, %n", name, sdf.format(System.currentTimeMillis())); } + + @Override + public long startTime() { + return 0; + } }