Remove runTaskSeparately method

This commit is contained in:
Roman Zhuravlev 2025-09-20 01:27:33 +05:00
parent 693d03efaf
commit 04f9fe30ae

View file

@ -25,9 +25,6 @@ import java.io.File;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.logging.Level;
public abstract class BukkitPreparedPlugin extends BukkitPlugin implements Listener, PreparedPlugin { public abstract class BukkitPreparedPlugin extends BukkitPlugin implements Listener, PreparedPlugin {
protected final Path dataDirectory; protected final Path dataDirectory;
@ -35,8 +32,6 @@ public abstract class BukkitPreparedPlugin extends BukkitPlugin implements Liste
protected final Language language = new Language(); protected final Language language = new Language();
protected final SqlAdapter sqlAdapter = createSqlAdapter(); protected final SqlAdapter sqlAdapter = createSqlAdapter();
private ExecutorService singleThreadExecutor;
public BukkitPreparedPlugin() { public BukkitPreparedPlugin() {
super(); super();
dataDirectory = getDataFolder().toPath(); dataDirectory = getDataFolder().toPath();
@ -178,10 +173,6 @@ public abstract class BukkitPreparedPlugin extends BukkitPlugin implements Liste
closeSqlAdapter(); closeSqlAdapter();
defaultConfig.clear(); defaultConfig.clear();
if (singleThreadExecutor != null) {
singleThreadExecutor.shutdownNow();
}
BukkitUtils.unregisterCommandIf(command -> command instanceof PluginIdentifiableCommand && ((PluginIdentifiableCommand) command).getPlugin() == this); BukkitUtils.unregisterCommandIf(command -> command instanceof PluginIdentifiableCommand && ((PluginIdentifiableCommand) command).getPlugin() == this);
} }
@ -195,18 +186,4 @@ public abstract class BukkitPreparedPlugin extends BukkitPlugin implements Liste
disable(); disable();
} }
} }
public void runTaskSeparately(Runnable runnable) {
if (singleThreadExecutor == null) {
singleThreadExecutor = Executors.newSingleThreadExecutor();
}
singleThreadExecutor.execute(() -> {
try {
runnable.run();
} catch (Throwable throwable) {
getLogger().log(Level.SEVERE, "Unhandled exception while running separated task", throwable);
}
});
}
} }