System-End/Discord-MC-Chat
1
0
Fork 0
mirror of https://github.com/System-End/Discord-MC-Chat.git synced 2026-04-19 20:55:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add callback executor

Browse source
This commit is contained in:
Xujiayao 2026-03-18 01:34:41 +08:00
parent 271734b780
commit ed61e30a76
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
core/src/main/java/com/xujiayao/discord_mc_chat/server/discord/DiscordManager.java
View file

@ -73,6 +73,7 @@ public class DiscordManager {
// Blocks until JDA is ready // Blocks until JDA is ready
CompletableFuture<Void> readyFuture = CompletableFuture.runAsync(() -> { CompletableFuture<Void> readyFuture = CompletableFuture.runAsync(() -> {
ExecutorService eventExecutor = Executors.newSingleThreadExecutor(ExecutorServiceUtils.newThreadFactory("DMCC-DiscordEvent")); ExecutorService eventExecutor = Executors.newSingleThreadExecutor(ExecutorServiceUtils.newThreadFactory("DMCC-DiscordEvent"));
ExecutorService callbackExecutor = Executors.newCachedThreadPool(ExecutorServiceUtils.newThreadFactory("DMCC-DiscordCallback"));
try { try {
jda = JDABuilder.createDefault(token) jda = JDABuilder.createDefault(token)
.enableIntents( .enableIntents(
@ -82,6 +83,7 @@ public class DiscordManager {
) )
.setMemberCachePolicy(MemberCachePolicy.ALL) .setMemberCachePolicy(MemberCachePolicy.ALL)
.setEventPool(eventExecutor, true) .setEventPool(eventExecutor, true)
.setCallbackPool(callbackExecutor, true)
.addEventListeners(new DiscordEventHandler()) .addEventListeners(new DiscordEventHandler())
.build(); .build();
@ -89,8 +91,9 @@ public class DiscordManager {
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOGGER.error(I18nManager.getDmccTranslation("discord.manager.init_interrupted"), e); LOGGER.error(I18nManager.getDmccTranslation("discord.manager.init_interrupted"), e);
} catch (RuntimeException e) { } catch (RuntimeException e) {
// If build() fails before JDA takes ownership of the event executor, shut it down to avoid leaks // If build() fails before JDA takes ownership of executors, shut them down to avoid leaks
eventExecutor.shutdownNow(); eventExecutor.shutdownNow();
callbackExecutor.shutdownNow();
throw e; throw e;
} }
}, executor); }, executor);