mirror of
https://github.com/PaperMC/Folia.git
synced 2024-09-09 01:38:31 +02:00
50ad6c3131
Now, entity/global/location schedulers implement a generic run, runDelayed, and runAtFixedRate methods that provide a ScheduledTask value that can be used to interact with the scheduled task. Add also an async task scheduler that implements the same methods, except the delays/periods are in time and not ticks, as the scheduler is independent of the server tick process. Additionally, throw on some unimplemented APIs now.
545 lines
27 KiB
Diff
545 lines
27 KiB
Diff
From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
|
|
From: Spottedleaf <Spottedleaf@users.noreply.github.com>
|
|
Date: Sat, 4 Mar 2023 12:48:43 -0800
|
|
Subject: [PATCH] Region scheduler API
|
|
|
|
Add both a location based scheduler, an entity based scheduler,
|
|
and a global region scheduler.
|
|
|
|
diff --git a/src/main/java/io/papermc/paper/threadedregions/scheduler/AsyncScheduler.java b/src/main/java/io/papermc/paper/threadedregions/scheduler/AsyncScheduler.java
|
|
new file mode 100644
|
|
index 0000000000000000000000000000000000000000..64d1fe385d30f1f5ab82d35fe66e268da13346b1
|
|
--- /dev/null
|
|
+++ b/src/main/java/io/papermc/paper/threadedregions/scheduler/AsyncScheduler.java
|
|
@@ -0,0 +1,50 @@
|
|
+package io.papermc.paper.threadedregions.scheduler;
|
|
+
|
|
+import org.bukkit.plugin.Plugin;
|
|
+import org.jetbrains.annotations.NotNull;
|
|
+import java.util.concurrent.TimeUnit;
|
|
+import java.util.function.Consumer;
|
|
+
|
|
+/**
|
|
+ * Scheduler that may be used by plugins to schedule tasks to execute asynchronously from the server tick process.
|
|
+ */
|
|
+public interface AsyncScheduler {
|
|
+
|
|
+ /**
|
|
+ * Schedules the specified task to be executed asynchronously immediately.
|
|
+ * @param plugin Plugin which owns the specified task.
|
|
+ * @param task Specified task.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runNow(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task);
|
|
+
|
|
+ /**
|
|
+ * Schedules the specified task to be executed asynchronously after the time delay has passed.
|
|
+ * @param plugin Plugin which owns the specified task.
|
|
+ * @param task Specified task.
|
|
+ * @param delay The time delay to pass before the task should be executed.
|
|
+ * @param unit The time unit for the time delay.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runDelayed(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task, long delay,
|
|
+ @NotNull TimeUnit unit);
|
|
+
|
|
+ /**
|
|
+ * Schedules the specified task to be executed asynchronously after the initial delay has passed,
|
|
+ * and then periodically executed with the specified period.
|
|
+ * @param plugin Plugin which owns the specified task.
|
|
+ * @param task Specified task.
|
|
+ * @param initialDelay The time delay to pass before the first execution of the task.
|
|
+ * @param period The time between task executions after the first execution of the task.
|
|
+ * @param unit The time unit for the initial delay and period.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runAtFixedRate(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task,
|
|
+ long initialDelay, long period, @NotNull TimeUnit unit);
|
|
+
|
|
+ /**
|
|
+ * Attempts to cancel all tasks scheduled by the specified plugin.
|
|
+ * @param plugin Specified plugin.
|
|
+ */
|
|
+ public void cancelTasks(@NotNull Plugin plugin);
|
|
+}
|
|
diff --git a/src/main/java/io/papermc/paper/threadedregions/scheduler/EntityScheduler.java b/src/main/java/io/papermc/paper/threadedregions/scheduler/EntityScheduler.java
|
|
new file mode 100644
|
|
index 0000000000000000000000000000000000000000..9c4ee07a86104f3601ba6d8a911197dbe1a17102
|
|
--- /dev/null
|
|
+++ b/src/main/java/io/papermc/paper/threadedregions/scheduler/EntityScheduler.java
|
|
@@ -0,0 +1,103 @@
|
|
+package io.papermc.paper.threadedregions.scheduler;
|
|
+
|
|
+import org.bukkit.plugin.Plugin;
|
|
+import org.jetbrains.annotations.NotNull;
|
|
+import org.jetbrains.annotations.Nullable;
|
|
+import java.util.function.Consumer;
|
|
+
|
|
+/**
|
|
+ * An entity can move between worlds with an arbitrary tick delay, be temporarily removed
|
|
+ * for players (i.e end credits), be partially removed from world state (i.e inactive but not removed),
|
|
+ * teleport between ticking regions, teleport between worlds, and even be removed entirely from the server.
|
|
+ * The uncertainty of an entity's state can make it difficult to schedule tasks without worrying about undefined
|
|
+ * behaviors resulting from any of the states listed previously.
|
|
+ *
|
|
+ * <p>
|
|
+ * This class is designed to eliminate those states by providing an interface to run tasks only when an entity
|
|
+ * is contained in a world, on the owning thread for the region, and by providing the current Entity object.
|
|
+ * The scheduler also allows a task to provide a callback, the "retired" callback, that will be invoked
|
|
+ * if the entity is removed before a task that was scheduled could be executed. The scheduler is also
|
|
+ * completely thread-safe, allowing tasks to be scheduled from any thread context. The scheduler also indicates
|
|
+ * properly whether a task was scheduled successfully (i.e scheduler not retired), thus the code scheduling any task
|
|
+ * knows whether the given callbacks will be invoked eventually or not - which may be critical for off-thread
|
|
+ * contexts.
|
|
+ * </p>
|
|
+ */
|
|
+public interface EntityScheduler {
|
|
+
|
|
+ /**
|
|
+ * Schedules a task with the given delay. If the task failed to schedule because the scheduler is retired (entity
|
|
+ * removed), then returns {@code false}. Otherwise, either the run callback will be invoked after the specified delay,
|
|
+ * or the retired callback will be invoked if the scheduler is retired.
|
|
+ * Note that the retired callback is invoked in critical code, so it should not attempt to remove the entity, remove
|
|
+ * other entities, load chunks, load worlds, modify ticket levels, etc.
|
|
+ *
|
|
+ * <p>
|
|
+ * It is guaranteed that the run and retired callback are invoked on the region which owns the entity.
|
|
+ * </p>
|
|
+ * @param run The callback to run after the specified delay, may not be null.
|
|
+ * @param retired Retire callback to run if the entity is retired before the run callback can be invoked, may be null.
|
|
+ * @param delay The delay in ticks before the run callback is invoked. Any value less-than 1 is treated as 1.
|
|
+ * @return {@code true} if the task was scheduled, which means that either the run function or the retired function
|
|
+ * will be invoked (but never both), or {@code false} indicating neither the run nor retired function will be invoked
|
|
+ * since the scheduler has been retired.
|
|
+ */
|
|
+ public boolean execute(@NotNull Plugin plugin, @NotNull Runnable run, @Nullable Runnable retired, long delay);
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to execute on the next tick. If the task failed to schedule because the scheduler is retired (entity
|
|
+ * removed), then returns {@code null}. Otherwise, either the task callback will be invoked after the specified delay,
|
|
+ * or the retired callback will be invoked if the scheduler is retired.
|
|
+ * Note that the retired callback is invoked in critical code, so it should not attempt to remove the entity, remove
|
|
+ * other entities, load chunks, load worlds, modify ticket levels, etc.
|
|
+ *
|
|
+ * <p>
|
|
+ * It is guaranteed that the task and retired callback are invoked on the region which owns the entity.
|
|
+ * </p>
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param task The task to execute
|
|
+ * @param retired Retire callback to run if the entity is retired before the run callback can be invoked, may be null.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task, or {@code null} if the entity has been removed.
|
|
+ */
|
|
+ public @Nullable ScheduledTask run(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task,
|
|
+ @Nullable Runnable retired);
|
|
+
|
|
+ /**
|
|
+ * Schedules a task with the given delay. If the task failed to schedule because the scheduler is retired (entity
|
|
+ * removed), then returns {@code null}. Otherwise, either the task callback will be invoked after the specified delay,
|
|
+ * or the retired callback will be invoked if the scheduler is retired.
|
|
+ * Note that the retired callback is invoked in critical code, so it should not attempt to remove the entity, remove
|
|
+ * other entities, load chunks, load worlds, modify ticket levels, etc.
|
|
+ *
|
|
+ * <p>
|
|
+ * It is guaranteed that the task and retired callback are invoked on the region which owns the entity.
|
|
+ * </p>
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param task The task to execute
|
|
+ * @param retired Retire callback to run if the entity is retired before the run callback can be invoked, may be null.
|
|
+ * @param delayTicks The delay, in ticks.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task, or {@code null} if the entity has been removed.
|
|
+ */
|
|
+ public @Nullable ScheduledTask runDelayed(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task,
|
|
+ @Nullable Runnable retired, int delayTicks);
|
|
+
|
|
+ /**
|
|
+ * Schedules a repeating task with the given delay and period. If the task failed to schedule because the scheduler
|
|
+ * is retired (entity removed), then returns {@code null}. Otherwise, either the task callback will be invoked after
|
|
+ * the specified delay, or the retired callback will be invoked if the scheduler is retired.
|
|
+ * Note that the retired callback is invoked in critical code, so it should not attempt to remove the entity, remove
|
|
+ * other entities, load chunks, load worlds, modify ticket levels, etc.
|
|
+ *
|
|
+ * <p>
|
|
+ * It is guaranteed that the task and retired callback are invoked on the region which owns the entity.
|
|
+ * </p>
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param task The task to execute
|
|
+ * @param retired Retire callback to run if the entity is retired before the run callback can be invoked, may be null.
|
|
+ * @param initialDelayTicks The initial delay, in ticks.
|
|
+ * @param periodTicks The period, in ticks.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task, or {@code null} if the entity has been removed.
|
|
+ */
|
|
+ public @Nullable ScheduledTask runAtFixedRate(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task,
|
|
+ @Nullable Runnable retired, int initialDelayTicks, int periodTicks);
|
|
+}
|
|
diff --git a/src/main/java/io/papermc/paper/threadedregions/scheduler/GlobalRegionScheduler.java b/src/main/java/io/papermc/paper/threadedregions/scheduler/GlobalRegionScheduler.java
|
|
new file mode 100644
|
|
index 0000000000000000000000000000000000000000..f2d2565d903af90f6909319c811a49162f972e27
|
|
--- /dev/null
|
|
+++ b/src/main/java/io/papermc/paper/threadedregions/scheduler/GlobalRegionScheduler.java
|
|
@@ -0,0 +1,57 @@
|
|
+package io.papermc.paper.threadedregions.scheduler;
|
|
+
|
|
+import org.bukkit.plugin.Plugin;
|
|
+import org.jetbrains.annotations.NotNull;
|
|
+import java.util.function.Consumer;
|
|
+
|
|
+/**
|
|
+ * The global region task scheduler may be used to schedule tasks that will execute on the global region.
|
|
+ * <p>
|
|
+ * The global region is responsible for maintaining world day time, world game time, weather cycle,
|
|
+ * sleep night skipping, executing commands for console, and other misc. tasks that do not belong to any specific region.
|
|
+ * </p>
|
|
+ */
|
|
+public interface GlobalRegionScheduler {
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to be executed on the global region.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param run The task to execute
|
|
+ */
|
|
+ public void execute(@NotNull Plugin plugin, @NotNull Runnable run);
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to be executed on the global region on the next tick.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param task The task to execute
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask run(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task);
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to be executed on the global region after the specified delay in ticks.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param task The task to execute
|
|
+ * @param delayTicks The delay, in ticks.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runDelayed(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task, int delayTicks);
|
|
+
|
|
+ /**
|
|
+ * Schedules a repeating task to be executed on the global region after the initial delay with the
|
|
+ * specified period.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param task The task to execute
|
|
+ * @param initialDelayTicks The initial delay, in ticks.
|
|
+ * @param periodTicks The period, in ticks.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runAtFixedRate(@NotNull Plugin plugin, @NotNull Consumer<ScheduledTask> task,
|
|
+ int initialDelayTicks, int periodTicks);
|
|
+
|
|
+ /**
|
|
+ * Attempts to cancel all tasks scheduled by the specified plugin.
|
|
+ * @param plugin Specified plugin.
|
|
+ */
|
|
+ public void cancelTasks(@NotNull Plugin plugin);
|
|
+}
|
|
diff --git a/src/main/java/io/papermc/paper/threadedregions/scheduler/RegionisedScheduler.java b/src/main/java/io/papermc/paper/threadedregions/scheduler/RegionisedScheduler.java
|
|
new file mode 100644
|
|
index 0000000000000000000000000000000000000000..4912d47e3daa4071bc82b1a32a19c8ea3348e0cc
|
|
--- /dev/null
|
|
+++ b/src/main/java/io/papermc/paper/threadedregions/scheduler/RegionisedScheduler.java
|
|
@@ -0,0 +1,60 @@
|
|
+package io.papermc.paper.threadedregions.scheduler;
|
|
+
|
|
+import org.bukkit.Location;
|
|
+import org.bukkit.entity.Entity;
|
|
+import org.bukkit.plugin.Plugin;
|
|
+import org.jetbrains.annotations.NotNull;
|
|
+import java.util.function.Consumer;
|
|
+
|
|
+/**
|
|
+ * The region task scheduler can be used to schedule tasks by location to be executed on the region which owns the location.
|
|
+ * <p>
|
|
+ * <b>Note</b>: It is entirely inappropriate to use the region scheduler to schedule tasks for entities.
|
|
+ * If you wish to schedule tasks to perform actions on entities, you should be using {@link Entity#getScheduler()}
|
|
+ * as the entity scheduler will "follow" an entity if it is teleported, whereas the region task scheduler
|
|
+ * will not.
|
|
+ * </p>
|
|
+ */
|
|
+public interface RegionisedScheduler {
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to be executed on the region which owns the location.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param location The location at which the region executing should own
|
|
+ * @param run The task to execute
|
|
+ */
|
|
+ public void execute(@NotNull Plugin plugin, @NotNull Location location, @NotNull Runnable run);
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to be executed on the region which owns the location on the next tick.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param location The location at which the region executing should own
|
|
+ * @param task The task to execute
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask run(@NotNull Plugin plugin, @NotNull Location location, @NotNull Consumer<ScheduledTask> task);
|
|
+
|
|
+ /**
|
|
+ * Schedules a task to be executed on the region which owns the location after the specified delay in ticks.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param location The location at which the region executing should own
|
|
+ * @param task The task to execute
|
|
+ * @param delayTicks The delay, in ticks.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runDelayed(@NotNull Plugin plugin, @NotNull Location location, @NotNull Consumer<ScheduledTask> task,
|
|
+ int delayTicks);
|
|
+
|
|
+ /**
|
|
+ * Schedules a repeating task to be executed on the region which owns the location after the initial delay with the
|
|
+ * specified period.
|
|
+ * @param plugin The plugin that owns the task
|
|
+ * @param location The location at which the region executing should own
|
|
+ * @param task The task to execute
|
|
+ * @param initialDelayTicks The initial delay, in ticks.
|
|
+ * @param periodTicks The period, in ticks.
|
|
+ * @return The {@link ScheduledTask} that represents the scheduled task.
|
|
+ */
|
|
+ public @NotNull ScheduledTask runAtFixedRate(@NotNull Plugin plugin, @NotNull Location location, @NotNull Consumer<ScheduledTask> task,
|
|
+ int initialDelayTicks, int periodTicks);
|
|
+}
|
|
diff --git a/src/main/java/io/papermc/paper/threadedregions/scheduler/ScheduledTask.java b/src/main/java/io/papermc/paper/threadedregions/scheduler/ScheduledTask.java
|
|
new file mode 100644
|
|
index 0000000000000000000000000000000000000000..fa4ac300d3721b2d6d84b95618d3305874cb803d
|
|
--- /dev/null
|
|
+++ b/src/main/java/io/papermc/paper/threadedregions/scheduler/ScheduledTask.java
|
|
@@ -0,0 +1,112 @@
|
|
+package io.papermc.paper.threadedregions.scheduler;
|
|
+
|
|
+import org.bukkit.plugin.Plugin;
|
|
+import org.jetbrains.annotations.NotNull;
|
|
+
|
|
+/**
|
|
+ * Represents a task scheduled to a scheduler.
|
|
+ */
|
|
+public interface ScheduledTask {
|
|
+
|
|
+ /**
|
|
+ * Returns the plugin that scheduled this task.
|
|
+ * @return the plugin that scheduled this task.
|
|
+ */
|
|
+ public @NotNull Plugin getOwningPlugin();
|
|
+
|
|
+ /**
|
|
+ * Returns whether this task executes on a fixed period, as opposed to executing only once.
|
|
+ * @return whether this task executes on a fixed period, as opposed to executing only once.
|
|
+ */
|
|
+ public boolean isRepeatingTask();
|
|
+
|
|
+ /**
|
|
+ * Attempts to cancel this task, returning the result of the attempt. In all cases, if the task is currently
|
|
+ * being executed no attempt is made to halt the task, however any executions in the future are halted.
|
|
+ * @return the result of the cancellation attempt.
|
|
+ */
|
|
+ public @NotNull CancelledState cancel();
|
|
+
|
|
+ /**
|
|
+ * Returns the current execution state of this task.
|
|
+ * @return the current execution state of this task.
|
|
+ */
|
|
+ public @NotNull ExecutionState getExecutionState();
|
|
+
|
|
+ /**
|
|
+ * Returns whether the current execution state is {@link ExecutionState#CANCELLED} or {@link ExecutionState#CANCELLED_RUNNING}.
|
|
+ * @return whether the current execution state is {@link ExecutionState#CANCELLED} or {@link ExecutionState#CANCELLED_RUNNING}.
|
|
+ */
|
|
+ public default boolean isCancelled() {
|
|
+ final ExecutionState state = this.getExecutionState();
|
|
+ return state == ExecutionState.CANCELLED || state == ExecutionState.CANCELLED_RUNNING;
|
|
+ }
|
|
+
|
|
+ /**
|
|
+ * Represents the result of attempting to cancel a task.
|
|
+ */
|
|
+ public enum CancelledState {
|
|
+ /**
|
|
+ * The task (repeating or not) has been successfully cancelled by the caller thread. The task is not executing
|
|
+ * currently, and it will not begin execution in the future.
|
|
+ */
|
|
+ CANCELLED_BY_CALLER,
|
|
+ /**
|
|
+ * The task (repeating or not) is already cancelled. The task is not executing currently, and it will not
|
|
+ * begin execution in the future.
|
|
+ */
|
|
+ CANCELLED_ALREADY,
|
|
+
|
|
+ /**
|
|
+ * The task is not a repeating task, and could not be cancelled because the task is being executed.
|
|
+ */
|
|
+ RUNNING,
|
|
+ /**
|
|
+ * The task is not a repeating task, and could not be cancelled because the task has already finished execution.
|
|
+ */
|
|
+ ALREADY_EXECUTED,
|
|
+
|
|
+ /**
|
|
+ * The caller thread successfully stopped future executions of a repeating task, but the task is currently
|
|
+ * being executed.
|
|
+ */
|
|
+ NEXT_RUNS_CANCELLED,
|
|
+
|
|
+ /**
|
|
+ * The repeating task's future executions are cancelled already, but the task is currently
|
|
+ * being executed.
|
|
+ */
|
|
+ NEXT_RUNS_CANCELLED_ALREADY,
|
|
+ }
|
|
+
|
|
+ /**
|
|
+ * Represents the current execution state of the task.
|
|
+ */
|
|
+ public enum ExecutionState {
|
|
+ /**
|
|
+ * The task is currently not executing, but may begin execution in the future.
|
|
+ */
|
|
+ IDLE,
|
|
+
|
|
+ /**
|
|
+ * The task is currently executing.
|
|
+ */
|
|
+ RUNNING,
|
|
+
|
|
+ /**
|
|
+ * The task is not repeating, and the task finished executing.
|
|
+ */
|
|
+ FINISHED,
|
|
+
|
|
+ /**
|
|
+ * The task is not executing and will not begin execution in the future. If this task is not repeating, then
|
|
+ * this task was never executed.
|
|
+ */
|
|
+ CANCELLED,
|
|
+
|
|
+ /**
|
|
+ * The task is repeating and currently executing, but future executions are cancelled and will not occur.
|
|
+ */
|
|
+ CANCELLED_RUNNING;
|
|
+ }
|
|
+}
|
|
diff --git a/src/main/java/org/bukkit/Bukkit.java b/src/main/java/org/bukkit/Bukkit.java
|
|
index ac9b690fcccb60b587e5345f12f1383afd0a73a1..22952628c894e29bfdb94897bd9970103730b898 100644
|
|
--- a/src/main/java/org/bukkit/Bukkit.java
|
|
+++ b/src/main/java/org/bukkit/Bukkit.java
|
|
@@ -2459,6 +2459,44 @@ public final class Bukkit {
|
|
return server.getPotionBrewer();
|
|
}
|
|
// Paper end
|
|
+ // Folia start - region threading API
|
|
+ /**
|
|
+ * Returns the region task scheduler. The region task scheduler can be used to schedule
|
|
+ * tasks by location to be executed on the region which owns the location.
|
|
+ * <p>
|
|
+ * <b>Note</b>: It is entirely inappropriate to use the region scheduler to schedule tasks for entities.
|
|
+ * If you wish to schedule tasks to perform actions on entities, you should be using {@link Entity#getScheduler()}
|
|
+ * as the entity scheduler will "follow" an entity if it is teleported, whereas the region task scheduler
|
|
+ * will not.
|
|
+ * </p>
|
|
+ * @return the region task scheduler
|
|
+ */
|
|
+ public static @NotNull io.papermc.paper.threadedregions.scheduler.RegionisedScheduler getRegionScheduler() {
|
|
+ return server.getRegionScheduler();
|
|
+ }
|
|
+
|
|
+ /**
|
|
+ * Returns the async task scheduler. The async task scheduler can be used to schedule tasks
|
|
+ * that execute asynchronously from the server tick process.
|
|
+ * @return the async task scheduler
|
|
+ */
|
|
+ public static @NotNull io.papermc.paper.threadedregions.scheduler.AsyncScheduler getAsyncScheduler() {
|
|
+ return server.getAsyncScheduler();
|
|
+ }
|
|
+
|
|
+ /**
|
|
+ * Returns the global region task scheduler. The global task scheduler can be used to schedule
|
|
+ * tasks to execute on the global region.
|
|
+ * <p>
|
|
+ * The global region is responsible for maintaining world day time, world game time, weather cycle,
|
|
+ * sleep night skipping, executing commands for console, and other misc. tasks that do not belong to any specific region.
|
|
+ * </p>
|
|
+ * @return the global region scheduler
|
|
+ */
|
|
+ public static @NotNull io.papermc.paper.threadedregions.scheduler.GlobalRegionScheduler getGlobalRegionScheduler() {
|
|
+ return server.getGlobalRegionScheduler();
|
|
+ }
|
|
+ // Folia end - region threading API
|
|
|
|
@NotNull
|
|
public static Server.Spigot spigot() {
|
|
diff --git a/src/main/java/org/bukkit/Server.java b/src/main/java/org/bukkit/Server.java
|
|
index 2204336d8800311b65e894739ab1b27273e7c6f2..ea4d93680066295de9fd447eda58b93014eac635 100644
|
|
--- a/src/main/java/org/bukkit/Server.java
|
|
+++ b/src/main/java/org/bukkit/Server.java
|
|
@@ -2139,4 +2139,36 @@ public interface Server extends PluginMessageRecipient, net.kyori.adventure.audi
|
|
*/
|
|
@NotNull org.bukkit.potion.PotionBrewer getPotionBrewer();
|
|
// Paper end
|
|
+ // Folia start - region threading API
|
|
+ /**
|
|
+ * Returns the region task scheduler. The region task scheduler can be used to schedule
|
|
+ * tasks by location to be executed on the region which owns the location.
|
|
+ * <p>
|
|
+ * <b>Note</b>: It is entirely inappropriate to use the region scheduler to schedule tasks for entities.
|
|
+ * If you wish to schedule tasks to perform actions on entities, you should be using {@link Entity#getScheduler()}
|
|
+ * as the entity scheduler will "follow" an entity if it is teleported, whereas the region task scheduler
|
|
+ * will not.
|
|
+ * </p>
|
|
+ * @return the region task scheduler
|
|
+ */
|
|
+ public @NotNull io.papermc.paper.threadedregions.scheduler.RegionisedScheduler getRegionScheduler();
|
|
+
|
|
+ /**
|
|
+ * Returns the async task scheduler. The async task scheduler can be used to schedule tasks
|
|
+ * that execute asynchronously from the server tick process.
|
|
+ * @return the async task scheduler
|
|
+ */
|
|
+ public @NotNull io.papermc.paper.threadedregions.scheduler.AsyncScheduler getAsyncScheduler();
|
|
+
|
|
+ /**
|
|
+ * Returns the global region task scheduler. The global task scheduler can be used to schedule
|
|
+ * tasks to execute on the global region.
|
|
+ * <p>
|
|
+ * The global region is responsible for maintaining world day time, world game time, weather cycle,
|
|
+ * sleep night skipping, executing commands for console, and other misc. tasks that do not belong to any specific region.
|
|
+ * </p>
|
|
+ * @return the global region scheduler
|
|
+ */
|
|
+ public @NotNull io.papermc.paper.threadedregions.scheduler.GlobalRegionScheduler getGlobalRegionScheduler();
|
|
+ // Folia end - region threading API
|
|
}
|
|
diff --git a/src/main/java/org/bukkit/entity/Entity.java b/src/main/java/org/bukkit/entity/Entity.java
|
|
index cdbc7329cf5f67d66e31eb31e83b9e7997040f72..90451ed12b2c95bb372ac2e3cbb57b8b83cc6a82 100644
|
|
--- a/src/main/java/org/bukkit/entity/Entity.java
|
|
+++ b/src/main/java/org/bukkit/entity/Entity.java
|
|
@@ -970,4 +970,13 @@ public interface Entity extends Metadatable, CommandSender, Nameable, Persistent
|
|
*/
|
|
boolean wouldCollideUsing(@NotNull BoundingBox boundingBox);
|
|
// Paper End - Collision API
|
|
+ // Folia start - region threading API
|
|
+ /**
|
|
+ * Returns the task scheduler for this entity. The entity scheduler can be used to schedule tasks
|
|
+ * that are guaranteed to always execute on the tick thread that owns the entity.
|
|
+ * @return the task scheduler for this entity.
|
|
+ * @see io.papermc.paper.threadedregions.scheduler.EntityScheduler
|
|
+ */
|
|
+ @NotNull io.papermc.paper.threadedregions.scheduler.EntityScheduler getScheduler();
|
|
+ // Folia end - region threading API
|
|
}
|
|
diff --git a/src/main/java/org/bukkit/plugin/SimplePluginManager.java b/src/main/java/org/bukkit/plugin/SimplePluginManager.java
|
|
index b012ce40d82389c29d1b841ff685425ac10a7f9e..057fa5dc78734520224af5031250b6be101ce3cb 100644
|
|
--- a/src/main/java/org/bukkit/plugin/SimplePluginManager.java
|
|
+++ b/src/main/java/org/bukkit/plugin/SimplePluginManager.java
|
|
@@ -585,9 +585,9 @@ public final class SimplePluginManager implements PluginManager {
|
|
}
|
|
|
|
try {
|
|
- server.getScheduler().cancelTasks(plugin);
|
|
+ server.getAsyncScheduler().cancelTasks(plugin); // Folia - new schedulers
|
|
} catch (Throwable ex) {
|
|
- handlePluginException("Error occurred (in the plugin loader) while cancelling tasks for "
|
|
+ handlePluginException("Error occurred (in the plugin loader) while cancelling async tasks for " // Folia - new schedulers
|
|
+ plugin.getDescription().getFullName() + " (Is it up to date?)", ex, plugin); // Paper
|
|
}
|
|
|