从 ListenerAdapter 创建线程会阻止它侦听事件 Java JDA



嗨,我正在研究这个JDA不和谐机器人,我正在为线程而苦苦挣扎。我的主机器人类扩展了 ListenerAdapter,我希望它侦听一个命令,然后启动计划服务以每周发布一次消息。问题是当创建线程时,它开始执行该任务,但主类停止侦听。

想知道我是否应该创建一个内部类,即 ListenerAdapter 并将它们都放在线程中,或者我是否缺少另一种解决方案。我在大学做过一些线程的工作,但没有太多经验。

public class Main extends ListenerAdapter {
static Thread SER;
public static void main(String[] args) throws LoginException {
... 
}
@Override
public void onMessageReceived(MessageReceivedEvent event){
if(event.getMessage().getContentRaw().equals("!startmessages")){
try {
SER = new Thread(new ScheduledExecutorRepeat(event.getChannel(),event.getGuild()));
ExecutorService executor = Executors.newCachedThreadPool();
executor.submit(SER);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Creating messages");
}
}
class ScheduledExecutorRepeat implements Runnable {
private int count = 0;
MessageChannel channel;
Guild guild;
ScheduledExecutorService ses;
ScheduledFuture<?> scheduledFuture;
public ScheduledExecutorRepeat(MessageChannel mc,Guild g) throws InterruptedException {
channel = mc;
guild = g;
ses = Executors.newScheduledThreadPool(1);
run();

}
public void run(){
Runnable task1 = () -> {
count++;
System.out.println("Running...Weekly Message - count : " + count);
};
// init Delay = 5, repeat the task every 1 second
scheduledFuture = ses.scheduleAtFixedRate(task1, 5, 1000*60*60*24*7, TimeUnit.SECONDS);
while (true) {
System.out.println("count :" + count);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

程序卡在 ScheduledExecutorRepeat 类末尾的循环中。 删除 while 循环解决了这个问题。计划的消息正常工作,机器人仍在侦听消息。

最新更新