diff --git a/src/main/java/com/hivekion/room/bean/Room.java b/src/main/java/com/hivekion/room/bean/Room.java index 0e9b211..7fc1543 100644 --- a/src/main/java/com/hivekion/room/bean/Room.java +++ b/src/main/java/com/hivekion/room/bean/Room.java @@ -102,6 +102,15 @@ public class Room implements AutoCloseable { public void stop() { status.set(false); cancelTask(); + futures.forEach((key, value) -> { + try { + if (!value.isShutdown()) { + value.shutdownNow(); + } + } catch (Exception e) { + log.error("error::", e); + } + }); } /** @@ -122,7 +131,6 @@ public class Room implements AutoCloseable { } - // 启动定时任务 private void startTask() { if (future == null || future.isCancelled()) { @@ -197,8 +205,9 @@ public class Room implements AutoCloseable { public boolean isRunning() { return status.get(); } + //统一推送方法 - protected void pushStatus(String resourceId){ + protected void pushStatus(String resourceId) { } }