small async packetsending change

This commit is contained in:
sirjonasxx 2018-06-13 23:47:36 +02:00
parent 684a30be3e
commit 86c694f8f8

View File

@ -25,15 +25,13 @@ public class HConnection {
public HConnection() { public HConnection() {
new Thread(() -> { new Thread(() -> {
while (true) { while (true) {
if (inHandler != null) { HPacket packet;
HPacket packet; while ((packet = sendToClientAsyncQueue.poll()) != null) {
while ((packet = sendToClientAsyncQueue.poll()) != null) { sendToClient(packet);
sendToClient(packet);
}
} }
try { try {
Thread.sleep(1); Thread.sleep(1);
} catch (InterruptedException e) { } catch (InterruptedException e) { //java........................................
e.printStackTrace(); e.printStackTrace();
} }
} }
@ -41,11 +39,9 @@ public class HConnection {
new Thread(() -> { new Thread(() -> {
while (true) { while (true) {
if (outHandler != null) { HPacket packet;
HPacket packet; while ((packet = sendToServerAsyncQueue.poll()) != null) {
while ((packet = sendToServerAsyncQueue.poll()) != null) { sendToServer(packet);
sendToServer(packet);
}
} }
try { try {
Thread.sleep(1); Thread.sleep(1);