diff --git a/proxy/dokodemo/dokodemo.go b/proxy/dokodemo/dokodemo.go
index 4b41d68c..971ed4a1 100644
--- a/proxy/dokodemo/dokodemo.go
+++ b/proxy/dokodemo/dokodemo.go
@@ -133,13 +133,19 @@ func (this *DokodemoDoor) HandleTCPConnection(conn *hub.TCPConn) {
 
 	reader := v2net.NewTimeOutReader(this.config.Timeout, conn)
 	go func() {
-		v2io.Pipe(v2io.NewAdaptiveReader(reader), ray.InboundInput())
+		v2reader := v2io.NewAdaptiveReader(reader)
+		defer v2reader.Release()
+
+		v2io.Pipe(v2reader, ray.InboundInput())
 		inputFinish.Unlock()
 		ray.InboundInput().Close()
 	}()
 
 	go func() {
-		v2io.Pipe(ray.InboundOutput(), v2io.NewAdaptiveWriter(conn))
+		v2writer := v2io.NewAdaptiveWriter(conn)
+		defer v2writer.Release()
+
+		v2io.Pipe(ray.InboundOutput(), v2writer)
 		outputFinish.Unlock()
 	}()
 
diff --git a/proxy/freedom/freedom.go b/proxy/freedom/freedom.go
index a3b1fd49..f4b7069f 100644
--- a/proxy/freedom/freedom.go
+++ b/proxy/freedom/freedom.go
@@ -51,7 +51,10 @@ func (this *FreedomConnection) Dispatch(firstPacket v2net.Packet, ray ray.Outbou
 		writeMutex.Unlock()
 	} else {
 		go func() {
-			v2io.Pipe(input, v2io.NewAdaptiveWriter(conn))
+			v2writer := v2io.NewAdaptiveWriter(conn)
+			defer v2writer.Release()
+
+			v2io.Pipe(input, v2writer)
 			writeMutex.Unlock()
 		}()
 	}
@@ -66,7 +69,10 @@ func (this *FreedomConnection) Dispatch(firstPacket v2net.Packet, ray ray.Outbou
 			reader = v2net.NewTimeOutReader(16 /* seconds */, conn)
 		}
 
-		v2io.Pipe(v2io.NewAdaptiveReader(reader), output)
+		v2reader := v2io.NewAdaptiveReader(reader)
+		defer v2reader.Release()
+
+		v2io.Pipe(v2reader, output)
 	}()
 
 	writeMutex.Lock()
diff --git a/proxy/http/http.go b/proxy/http/http.go
index dacf3996..8c53bc3a 100644
--- a/proxy/http/http.go
+++ b/proxy/http/http.go
@@ -154,13 +154,19 @@ func (this *HttpProxyServer) transport(input io.Reader, output io.Writer, ray ra
 	defer wg.Wait()
 
 	go func() {
-		v2io.Pipe(v2io.NewAdaptiveReader(input), ray.InboundInput())
+		v2reader := v2io.NewAdaptiveReader(input)
+		defer v2reader.Release()
+
+		v2io.Pipe(v2reader, ray.InboundInput())
 		ray.InboundInput().Close()
 		wg.Done()
 	}()
 
 	go func() {
-		v2io.Pipe(ray.InboundOutput(), v2io.NewAdaptiveWriter(output))
+		v2writer := v2io.NewAdaptiveWriter(output)
+		defer v2writer.Release()
+
+		v2io.Pipe(ray.InboundOutput(), v2writer)
 		ray.InboundOutput().Release()
 		wg.Done()
 	}()
diff --git a/proxy/shadowsocks/shadowsocks.go b/proxy/shadowsocks/shadowsocks.go
index 671aed99..70b4d081 100644
--- a/proxy/shadowsocks/shadowsocks.go
+++ b/proxy/shadowsocks/shadowsocks.go
@@ -219,7 +219,10 @@ func (this *Shadowsocks) handleConnection(conn *hub.TCPConn) {
 			payload.Release()
 
 			writer := crypto.NewCryptionWriter(stream, conn)
-			v2io.Pipe(ray.InboundOutput(), v2io.NewAdaptiveWriter(writer))
+			v2writer := v2io.NewAdaptiveWriter(writer)
+			defer writer.Release()
+
+			v2io.Pipe(ray.InboundOutput(), v2writer)
 			ray.InboundOutput().Release()
 		}
 		writeFinish.Unlock()
diff --git a/proxy/socks/socks.go b/proxy/socks/socks.go
index 5b7125d3..24de3d2c 100644
--- a/proxy/socks/socks.go
+++ b/proxy/socks/socks.go
@@ -276,13 +276,19 @@ func (this *SocksServer) transport(reader io.Reader, writer io.Writer, firstPack
 	outputFinish.Lock()
 
 	go func() {
-		v2io.Pipe(v2io.NewAdaptiveReader(reader), input)
+		v2reader := v2io.NewAdaptiveReader(reader)
+		defer v2reader.Release()
+
+		v2io.Pipe(v2reader, input)
 		inputFinish.Unlock()
 		input.Close()
 	}()
 
 	go func() {
-		v2io.Pipe(output, v2io.NewAdaptiveWriter(writer))
+		v2writer := v2io.NewAdaptiveWriter(writer)
+		defer v2writer.Release()
+
+		v2io.Pipe(output, v2writer)
 		outputFinish.Unlock()
 		output.Release()
 	}()
diff --git a/proxy/testing/mocks/inboundhandler.go b/proxy/testing/mocks/inboundhandler.go
index d350a4b0..b528eefd 100644
--- a/proxy/testing/mocks/inboundhandler.go
+++ b/proxy/testing/mocks/inboundhandler.go
@@ -42,13 +42,19 @@ func (this *InboundConnectionHandler) Communicate(packet v2net.Packet) error {
 	writeFinish.Lock()
 
 	go func() {
-		v2io.Pipe(v2io.NewAdaptiveReader(this.ConnInput), input)
+		v2reader := v2io.NewAdaptiveReader(this.ConnInput)
+		defer v2reader.Release()
+
+		v2io.Pipe(v2reader, input)
 		input.Close()
 		readFinish.Unlock()
 	}()
 
 	go func() {
-		v2io.Pipe(output, v2io.NewAdaptiveWriter(this.ConnOutput))
+		v2writer := v2io.NewAdaptiveWriter(this.ConnOutput)
+		defer v2writer.Release()
+
+		v2io.Pipe(output, v2writer)
 		output.Release()
 		writeFinish.Unlock()
 	}()
diff --git a/proxy/testing/mocks/outboundhandler.go b/proxy/testing/mocks/outboundhandler.go
index fc9517ff..7f796a53 100644
--- a/proxy/testing/mocks/outboundhandler.go
+++ b/proxy/testing/mocks/outboundhandler.go
@@ -33,7 +33,10 @@ func (this *OutboundConnectionHandler) Dispatch(packet v2net.Packet, ray ray.Out
 		writeFinish.Lock()
 
 		go func() {
-			v2io.Pipe(input, v2io.NewAdaptiveWriter(this.ConnOutput))
+			v2writer := v2io.NewAdaptiveWriter(this.ConnOutput)
+			defer v2writer.Release()
+
+			v2io.Pipe(input, v2writer)
 			writeFinish.Unlock()
 			input.Release()
 		}()
@@ -41,7 +44,10 @@ func (this *OutboundConnectionHandler) Dispatch(packet v2net.Packet, ray ray.Out
 		writeFinish.Lock()
 	}
 
-	v2io.Pipe(v2io.NewAdaptiveReader(this.ConnInput), output)
+	v2reader := v2io.NewAdaptiveReader(this.ConnInput)
+	defer v2reader.Release()
+
+	v2io.Pipe(v2reader, output)
 	output.Close()
 
 	return nil