udp优化

2023-02-07 14:26:14 +08:00
parent 35fddb48de
commit 7d2a9f6d94
1 changed files with 4 additions and 2 deletions
--- a/src/main/java/org/redkale/net/AsyncNioUdpConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioUdpConnection.java
@@ -134,8 +134,10 @@ class AsyncNioUdpConnection extends AsyncNioConnection {
    }

    void receiveBuffer(ByteBuffer buf) {
-        revbufferQueue.offer(buf.flip());
-        doRead(true);
+        this.ioReadThread.execute(() -> {
+            revbufferQueue.offer(buf.flip());
+            doRead(this.ioReadThread.inCurrThread());
+        });
    }

    @Override