From 93ab948eb720c5d64e603a449b13b3388bc09d13 Mon Sep 17 00:00:00 2001 From: Reider745 <70357814+Reider745@users.noreply.github.com> Date: Tue, 2 Apr 2024 19:13:08 +0300 Subject: [PATCH] =?UTF-8?q?Fix=20=D0=B2=D1=85=D0=BE=D0=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../network/innercore/PlayerSocketSendingThread.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/reider745/network/innercore/PlayerSocketSendingThread.java b/src/main/java/com/reider745/network/innercore/PlayerSocketSendingThread.java index 9150d217..47d97251 100644 --- a/src/main/java/com/reider745/network/innercore/PlayerSocketSendingThread.java +++ b/src/main/java/com/reider745/network/innercore/PlayerSocketSendingThread.java @@ -25,10 +25,10 @@ public class PlayerSocketSendingThread extends Thread { } public void send(DataPacket packet){ - list.addLast(packet); + list.addFirst(packet); } - private static boolean isClose = false; + private boolean isClose = false; @Override public void run() { @@ -57,8 +57,14 @@ public class PlayerSocketSendingThread extends Thread { public void close(){ long start = System.currentTimeMillis(); - while (list.size() <= 15 && !list.isEmpty() && System.currentTimeMillis() - start <= 1000L){} + while ((list.size() <= 15 && !list.isEmpty()) || System.currentTimeMillis() - start <= 1000L){ + try { + Thread.sleep(10); + }catch (Exception ignore){} + } + isClose = true; + try { outputStream.close(); } catch (IOException e) {