Merge remote-tracking branch 'origin/master'
This commit is contained in:
commit
8480f5a52d
2 changed files with 2 additions and 4 deletions
|
@ -46,9 +46,7 @@ class SchedulerImpl implements Scheduler {
|
|||
TaskSchedule schedule = task.task.get();
|
||||
if (schedule instanceof TaskSchedule.DurationSchedule) {
|
||||
TaskSchedule.DurationSchedule d = (TaskSchedule.DurationSchedule) schedule;
|
||||
SCHEDULED_EXECUTOR.schedule(() -> {
|
||||
safeExecute(task);
|
||||
}, d.duration.toMillis(), TimeUnit.MILLISECONDS);
|
||||
SCHEDULED_EXECUTOR.schedule(() -> safeExecute(task), d.duration.toMillis(), TimeUnit.MILLISECONDS);
|
||||
}
|
||||
else if (schedule instanceof TaskSchedule.FutureSchedule) {
|
||||
TaskSchedule.FutureSchedule f = (TaskSchedule.FutureSchedule) schedule;
|
||||
|
|
|
@ -20,7 +20,7 @@ public interface Task {
|
|||
private final Runnable runnable;
|
||||
private final Scheduler scheduler;
|
||||
|
||||
private ExecutionType executionType = ExecutionType.SYNC;//default
|
||||
private ExecutionType executionType = ExecutionType.BLOCKING;//default
|
||||
private TaskSchedule delay = TaskSchedule.immediate();
|
||||
private TaskSchedule repeat = TaskSchedule.stop();
|
||||
|
||||
|
|
Loading…
Reference in a new issue