From 15f856b76288af503b0e60e94b57eb7bd7295010 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Mon, 30 Jul 2018 15:26:47 +0800
Subject: [PATCH]

---
 src/org/redkale/net/AsyncConnection.java | 11 +++++++++++
 1 file changed, 11 insertions(+)

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<AsyncConnection> 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();