From 0c66a95a420ebc2b1f749a893eed4cc4681085c4 Mon Sep 17 00:00:00 2001 From: Tofaa2 Date: Mon, 8 Jul 2024 18:36:48 +0400 Subject: [PATCH] replace sync with blocking since theres no sync --- .../me/tofaa/entitylib/standalone/task/SchedulerImpl.java | 4 +--- .../main/java/me/tofaa/entitylib/standalone/task/Task.java | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/SchedulerImpl.java b/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/SchedulerImpl.java index ffee587..9dbef2b 100644 --- a/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/SchedulerImpl.java +++ b/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/SchedulerImpl.java @@ -46,9 +46,7 @@ private void handleTask(TaskImpl task) { 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; diff --git a/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/Task.java b/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/Task.java index f9cd1e6..6bfb4d7 100644 --- a/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/Task.java +++ b/platforms/standalone/src/main/java/me/tofaa/entitylib/standalone/task/Task.java @@ -20,7 +20,7 @@ class Builder { 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();