From 7d2a9f6d9490256a0e328716dc8435d92acc2d05 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Tue, 7 Feb 2023 14:26:14 +0800
Subject: [PATCH] =?UTF-8?q?udp=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/AsyncNioUdpConnection.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/redkale/net/AsyncNioUdpConnection.java b/src/main/java/org/redkale/net/AsyncNioUdpConnection.java
index cb5f7b636..85fcd654d 100644
--- 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