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

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

diff --git a/src/org/redkale/net/AsyncConnection.java b/src/org/redkale/net/AsyncConnection.java
index f54ba5bd9..f395ad474 100644
--- a/src/org/redkale/net/AsyncConnection.java
+++ b/src/org/redkale/net/AsyncConnection.java
@@ -11,7 +11,7 @@ import java.nio.ByteBuffer;
 import java.nio.channels.*;
 import java.util.*;
 import java.util.concurrent.*;
-import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.atomic.*;
 import java.util.function.Consumer;
 import javax.net.ssl.SSLContext;
 
@@ -43,7 +43,7 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl
     protected Consumer<AsyncConnection> beforeCloseListener;
 
     //关联的事件数， 小于1表示没有事件
-    protected final AtomicLong eventing = new AtomicLong();
+    protected final AtomicInteger eventing = new AtomicInteger();
 
     public final long getLastReadTime() {
         return readtime;
@@ -53,11 +53,11 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl
         return writetime;
     }
 
-    public final long increEventing() {
+    public final int increEventing() {
         return eventing.incrementAndGet();
     }
 
-    public final long decreEventing() {
+    public final int decreEventing() {
         return eventing.decrementAndGet();
     }