diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java index 1c74a87f9..8806c0653 100644 --- a/src/main/java/org/redkale/net/AsyncConnection.java +++ b/src/main/java/org/redkale/net/AsyncConnection.java @@ -289,28 +289,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable { } } - public final void readRegisterInIOThread(CompletionHandler handler) { - if (inCurrReadThread()) { - readRegister(handler); - } else { - executeRead(() -> readRegister(handler)); - } - } - - public final void readRegisterInIOThreadSafe(CompletionHandler handler) { - if (inCurrReadThread()) { - if (!readPending) { - readRegister(handler); - } - } else { - executeRead(() -> { - if (!readPending) { - readRegister(handler); - } - }); - } - } - public final void read(CompletionHandler handler) { if (sslEngine == null) { readImpl(handler); @@ -327,20 +305,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable { } } - public final void readInIOThreadSafe(CompletionHandler handler) { - if (inCurrReadThread()) { - if (!readPending) { - read(handler); - } - } else { - executeRead(() -> { - if (!readPending) { - read(handler); - } - }); - } - } - // src写完才会回调 public final void write(ByteBuffer src, A attachment, CompletionHandler handler) { if (sslEngine == null) {