added more of a "buffer" for laggy connections

This commit is contained in:
ajgeiss0702
2021-07-31 11:12:55 -07:00
parent 86744676c0
commit 090199b7ff
@@ -63,14 +63,14 @@ public class TaskManager {
actionBarTask = scheduleAtFixedRate( actionBarTask = scheduleAtFixedRate(
main.getQueueManager()::sendActionBars, main.getQueueManager()::sendActionBars,
2L, 1500L,
TimeUnit.SECONDS TimeUnit.MILLISECONDS
); );
queueEventTask = scheduleAtFixedRate( queueEventTask = scheduleAtFixedRate(
main.getQueueManager()::sendQueueEvents, main.getQueueManager()::sendQueueEvents,
2L, 1500L,
TimeUnit.SECONDS TimeUnit.MILLISECONDS
); );
if(main.getConfig().getInt("reload-servers-interval") > 0) { if(main.getConfig().getInt("reload-servers-interval") > 0) {
@@ -85,22 +85,22 @@ public class TaskManager {
public void cancelTasks() { public void cancelTasks() {
if(sendTask != null && !sendTask.isCancelled()) { if(sendTask != null && !sendTask.isCancelled()) {
sendTask.cancel(false); sendTask.cancel(true);
} }
if(updateTask != null && !updateTask.isCancelled()) { if(updateTask != null && !updateTask.isCancelled()) {
updateTask.cancel(true); updateTask.cancel(true);
} }
if(messageTask != null && !messageTask.isCancelled()) { if(messageTask != null && !messageTask.isCancelled()) {
messageTask.cancel(false); messageTask.cancel(true);
} }
if(actionBarTask != null && !actionBarTask.isCancelled()) { if(actionBarTask != null && !actionBarTask.isCancelled()) {
actionBarTask.cancel(false); actionBarTask.cancel(true);
} }
if(queueEventTask != null && !queueEventTask.isCancelled()) { if(queueEventTask != null && !queueEventTask.isCancelled()) {
queueEventTask.cancel(false); queueEventTask.cancel(true);
} }
if(reloadServerTask != null && !reloadServerTask.isCancelled()) { if(reloadServerTask != null && !reloadServerTask.isCancelled()) {
reloadServerTask.cancel(false); reloadServerTask.cancel(true);
reloadServerTask = null; reloadServerTask = null;
} }
} }