Version 1.1.6

Add getPendingTasks
Euphillya · Mar 16, 2024 · d269c41 · d269c41
1 parent 4dee836
commit d269c41
Show file tree

Hide file tree

Showing 6 changed files with 30 additions and 2 deletions.
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -4,7 +4,7 @@ plugins {
 }
 
 group = "fr.euphyllia"
-version = "1.1.5"
+version = "1.1.6"
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/fr/euphyllia/energie/executors/ExecutorsScheduler.java b/src/main/java/fr/euphyllia/energie/executors/ExecutorsScheduler.java
@@ -7,6 +7,8 @@
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.*;
 
@@ -212,6 +214,11 @@ public void execute(@NotNull SchedulerType schedulerType, @Nullable Object chunk
         throw new UnsupportedOperationException();
     }
 
+    @Override
+    public List<SchedulerTaskInter> getPendingTasks() {
+        return new ArrayList<>(mapSchedulerTask.values());
+    }
+
     @Override
     public void cancelAllTask() {
         for (Map.Entry<Integer, SchedulerTaskInter> entry : mapSchedulerTask.entrySet()) {

diff --git a/src/main/java/fr/euphyllia/energie/folia/FoliaScheduler.java b/src/main/java/fr/euphyllia/energie/folia/FoliaScheduler.java
@@ -10,10 +10,13 @@
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 public class FoliaScheduler implements Scheduler {
 
@@ -471,6 +474,11 @@ public void execute(@NotNull SchedulerType schedulerType, @Nullable Object chunk
         }
     }
 
+    @Override
+    public List<SchedulerTaskInter> getPendingTasks() {
+        return new ArrayList<>(mapSchedulerTask.values());
+    }
+
     @Override
     public void cancelAllTask() {
         for (Map.Entry<Integer, SchedulerTaskInter> entry : mapSchedulerTask.entrySet()) {

diff --git a/src/main/java/fr/euphyllia/energie/legacy/LegacyScheduler.java b/src/main/java/fr/euphyllia/energie/legacy/LegacyScheduler.java
@@ -9,8 +9,11 @@
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.concurrent.Future;
 import java.util.concurrent.atomic.AtomicReference;
+import java.util.stream.Collectors;
 
 public class LegacyScheduler implements Scheduler {
     private final Plugin plugin;
@@ -265,6 +268,11 @@ public void execute(@NotNull SchedulerType schedulerType, @Nullable Object chunk
         this.scheduleSyncDelayed(schedulerType, callBack);
     }
 
+    @Override
+    public List<SchedulerTaskInter> getPendingTasks() {
+        return Bukkit.getScheduler().getPendingTasks().stream().map(LegacySchedulerTask::new).collect(Collectors.toList());
+    }
+
     @Override
     public void cancelAllTask() {
         Bukkit.getScheduler().cancelTasks(this.plugin);

diff --git a/src/main/java/fr/euphyllia/energie/model/Scheduler.java b/src/main/java/fr/euphyllia/energie/model/Scheduler.java
@@ -6,6 +6,7 @@
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
+import java.util.List;
 import java.util.concurrent.Future;
 
 public interface Scheduler {
@@ -85,6 +86,7 @@ public interface Scheduler {
     @Deprecated
     void execute(@NotNull SchedulerType schedulerType, @Nullable Object chunkOrLocOrEntity, @Nullable Runnable retired, SchedulerCallBack callBack);
 
+    List<SchedulerTaskInter> getPendingTasks();
 
     void cancelAllTask();