Improve performance on extremely long queues making one full loop

AlexProgrammerDE · Nov 1, 2022 · 141c17c · 141c17c
1 parent 92d2268
commit 141c17c
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/src/main/java/net/pistonmaster/pistonqueue/shared/QueueListenerShared.java b/src/main/java/net/pistonmaster/pistonqueue/shared/QueueListenerShared.java
@@ -34,7 +34,6 @@
 import java.time.Instant;
 import java.util.*;
 import java.util.concurrent.ThreadLocalRandom;
-import java.util.concurrent.atomic.AtomicInteger;
 
 @RequiredArgsConstructor
 public abstract class QueueListenerShared {
@@ -296,17 +295,19 @@ private void connectPlayer(QueueType type) {
  }
  }
 
+ @SuppressWarnings("UnstableApiUsage")
  private void sendXPSoundToQueueType(QueueType type) {
- @SuppressWarnings("UnstableApiUsage")
  ByteArrayDataOutput out = ByteStreams.newDataOutput();
  out.writeUTF("xp");
 
- AtomicInteger counter = new AtomicInteger(0);
- type.getQueueMap().forEach((uuid, server) -> {
- if (counter.incrementAndGet() <= 5) {
- out.writeUTF(uuid.toString());
+ int counter = 0;
+ for (UUID uuid : type.getQueueMap().keySet()) {
+ if (++counter > 5) {
+ break;
  }
- });
+
+ out.writeUTF(uuid.toString());
+ }
 
  plugin.getServer(Config.QUEUE_SERVER).ifPresent(server ->
  server.sendPluginMessage("piston:queue", out.toByteArray()));