diff --git a/src/org/redkale/net/AsyncConnection.java b/src/org/redkale/net/AsyncConnection.java index 6fa40e71d..f54ba5bd9 100644 --- a/src/org/redkale/net/AsyncConnection.java +++ b/src/org/redkale/net/AsyncConnection.java @@ -42,6 +42,9 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl protected Consumer beforeCloseListener; + //关联的事件数, 小于1表示没有事件 + protected final AtomicLong eventing = new AtomicLong(); + public final long getLastReadTime() { return readtime; } @@ -50,6 +53,14 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl return writetime; } + public final long increEventing() { + return eventing.incrementAndGet(); + } + + public final long decreEventing() { + return eventing.decrementAndGet(); + } + public abstract boolean isTCP(); public abstract boolean shutdownInput();