Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2025-01-01 05:58:00 +01:00
Code Issues Projects Releases Wiki Activity

Use a parallel stream for flushing

Browse Source 
Signed-off-by: TheMode <themode@outlook.fr>
This commit is contained in:
TheMode 2021-09-23 11:32:13 +02:00
parent 68107c9a90
commit 619a9b3209
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/net/minestom/server/UpdateManager.java
View File

@ -1,7 +1,6 @@
package net.minestom.server; package net.minestom.server;
import net.minestom.server.acquirable.Acquirable; import net.minestom.server.acquirable.Acquirable;
import net.minestom.server.entity.Player;
import net.minestom.server.instance.Chunk; import net.minestom.server.instance.Chunk;
import net.minestom.server.instance.Instance; import net.minestom.server.instance.Instance;
import net.minestom.server.instance.InstanceManager; import net.minestom.server.instance.InstanceManager;
@ -9,7 +8,6 @@ import net.minestom.server.monitoring.TickMonitor;
import net.minestom.server.network.ConnectionManager; import net.minestom.server.network.ConnectionManager;
import net.minestom.server.thread.ThreadDispatcher; import net.minestom.server.thread.ThreadDispatcher;
import net.minestom.server.utils.PacketUtils; import net.minestom.server.utils.PacketUtils;
import net.minestom.server.utils.async.AsyncUtils;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import java.util.List; import java.util.List;
@ -201,12 +199,9 @@ public final class UpdateManager {
} }
// Flush all waiting packets // Flush all waiting packets
AsyncUtils.runAsync(() -> { PacketUtils.flush();
PacketUtils.flush(); connectionManager.getOnlinePlayers().parallelStream().forEach(player ->
for (Player player : MinecraftServer.getConnectionManager().getOnlinePlayers()) { player.getPlayerConnection().flush());
player.getPlayerConnection().flush();
}
});
// Disable thread until next tick // Disable thread until next tick
LockSupport.parkNanos((long) ((MinecraftServer.TICK_MS * 1e6) - tickTime)); LockSupport.parkNanos((long) ((MinecraftServer.TICK_MS * 1e6) - tickTime));