Fix scheduler use during plugin shutdown

Author: Arbousier1

src/main/java/top/ellan/mahjong/runtime/ServerScheduler.java

@@ -29,7 +29,7 @@ public ServerScheduler(Plugin plugin) {
     }
 
     public PluginTask runGlobal(Runnable runnable) {
-        if (runnable == null) {
+        if (runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.globalRegionScheduler();
@@ -49,7 +49,7 @@ public PluginTask runGlobal(Runnable runnable) {
     }
 
     public PluginTask runGlobalDelayed(Runnable runnable, long delayTicks) {
-        if (runnable == null) {
+        if (runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.globalRegionScheduler();
@@ -70,7 +70,7 @@ public PluginTask runGlobalDelayed(Runnable runnable, long delayTicks) {
     }
 
     public PluginTask runGlobalTimer(Runnable runnable, long delayTicks, long periodTicks) {
-        if (runnable == null) {
+        if (runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.globalRegionScheduler();
@@ -92,7 +92,7 @@ public PluginTask runGlobalTimer(Runnable runnable, long delayTicks, long period
     }
 
     public PluginTask runRegion(Location location, Runnable runnable) {
-        if (location == null || location.getWorld() == null || runnable == null) {
+        if (location == null || location.getWorld() == null || runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.regionScheduler();
@@ -113,7 +113,7 @@ public PluginTask runRegion(Location location, Runnable runnable) {
     }
 
     public PluginTask runRegionDelayed(Location location, Runnable runnable, long delayTicks) {
-        if (location == null || location.getWorld() == null || runnable == null) {
+        if (location == null || location.getWorld() == null || runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.regionScheduler();
@@ -135,7 +135,7 @@ public PluginTask runRegionDelayed(Location location, Runnable runnable, long de
     }
 
     public PluginTask runRegionTimer(Location location, Runnable runnable, long delayTicks, long periodTicks) {
-        if (location == null || location.getWorld() == null || runnable == null) {
+        if (location == null || location.getWorld() == null || runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.regionScheduler();
@@ -158,7 +158,7 @@ public PluginTask runRegionTimer(Location location, Runnable runnable, long dela
     }
 
     public PluginTask runEntity(Entity entity, Runnable runnable) {
-        if (entity == null || runnable == null) {
+        if (entity == null || runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.entityScheduler(entity);
@@ -179,7 +179,7 @@ public PluginTask runEntity(Entity entity, Runnable runnable) {
     }
 
     public PluginTask runEntityDelayed(Entity entity, Runnable runnable, long delayTicks) {
-        if (entity == null || runnable == null) {
+        if (entity == null || runnable == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Object scheduler = this.entityScheduler(entity);
@@ -202,7 +202,7 @@ public PluginTask runEntityDelayed(Entity entity, Runnable runnable, long delayT
 
     @SuppressWarnings("unchecked")
     public CompletableFuture<Boolean> teleport(Entity entity, Location location) {
-        if (entity == null || location == null) {
+        if (entity == null || location == null || !this.isPluginEnabled()) {
             return CompletableFuture.completedFuture(Boolean.FALSE);
         }
         try {
@@ -231,7 +231,7 @@ public PluginTask removeEntity(Entity entity) {
     }
 
     public PluginTask removeEntity(Entity entity, long delayTicks) {
-        if (entity == null) {
+        if (entity == null || !this.isPluginEnabled()) {
             return NO_OP_TASK;
         }
         Runnable removeTask = () -> {
@@ -257,6 +257,10 @@ private Object entityScheduler(Entity entity) {
         return this.invokeNoArgs(entity, "getScheduler");
     }
 
+    private boolean isPluginEnabled() {
+        return this.plugin.isEnabled();
+    }
+
     private Object invokeNoArgs(Object target, String methodName) {
         if (target == null) {
             return null;

src/main/java/top/ellan/mahjong/table/presentation/TableViewerPresentationCoordinator.java

@@ -85,7 +85,7 @@ public void shutdown() {
         this.markDirty();
         this.nextOverlayRefreshTick = 0L;
         this.nextHudRefreshTick = 0L;
-        this.clearHud();
+        this.clearHudImmediately();
     }
 
     public void hideHud(UUID viewerId) {
@@ -103,6 +103,17 @@ public void clearHud() {
         }
     }
 
+    private void clearHudImmediately() {
+        for (UUID viewerId : List.copyOf(this.viewerHudBars.keySet())) {
+            BossBar bar = this.viewerHudBars.remove(viewerId);
+            this.viewerHudState.remove(viewerId);
+            Player player = this.session.onlinePlayer(viewerId);
+            if (bar != null && player != null) {
+                player.hideBossBar(bar);
+            }
+        }
+    }
+
     private void flushOverlay(long nowTick) {
         this.updateViewerOverlayRegions();
         this.viewerOverlayDirty = false;