diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go
index c86fe6e6..d2bafec9 100644
--- a/transport/internet/kcp/connection.go
+++ b/transport/internet/kcp/connection.go
@@ -392,6 +392,8 @@ func (this *Connection) Terminate() {
 	log.Info("KCP|Connection: Terminating connection to ", this.RemoteAddr())
 
 	this.SetState(StateTerminated)
+	this.dataInputCond.Broadcast()
+	this.dataOutputCond.Broadcast()
 	this.writer.Close()
 }