gh-24 remove Pool on connection

Unknow0 · Nov 25, 2023 · 6438fc8 · 6438fc8
1 parent ec8b5d6
commit 6438fc8
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 15 deletions.
diff --git a/unknow-server-nio/src/main/java/unknow/server/nio/NIOConnection.java b/unknow-server-nio/src/main/java/unknow/server/nio/NIOConnection.java
@@ -243,7 +243,7 @@ public final void free() throws InterruptedException, IOException {
 		pendingWrite.clear();
 		pendingRead.clear();
 		onFree();
-		pool.free(this);
+//		pool.free(this);
 	}
 
 	@SuppressWarnings("resource")

diff --git a/unknow-server-util/src/main/java/unknow/server/util/io/Buffers.java b/unknow-server-util/src/main/java/unknow/server/util/io/Buffers.java
@@ -584,15 +584,14 @@ private Chunk() {
 		 * @return a chunk
 		 */
 		public static Chunk get() {
-			return new Chunk();
-//			synchronized (mutex) {
-//				if (idle == null)
-//					return new Chunk();
-//				Chunk c = idle;
-//				idle = idle.next;
-//				c.next = null;
-//				return c;
-//			}
+			synchronized (mutex) {
+				if (idle == null)
+					return new Chunk();
+				Chunk c = idle;
+				idle = idle.next;
+				c.next = null;
+				return c;
+			}
 		}
 
 		/**
@@ -603,11 +602,11 @@ public static Chunk get() {
 		 */
 		public static Chunk free(Chunk c) {
 			Chunk n = c.next;
-//			c.o = c.l = 0;
-//			synchronized (mutex) {
-//				c.next = idle;
-//				idle = c;
-//			}
+			c.o = c.l = 0;
+			synchronized (mutex) {
+				c.next = idle;
+				idle = c;
+			}
 			return n;
 		}
 	}