diff --git a/prepare_stmt.go b/prepare_stmt.go
index 0d2ed15eb..a59552d25 100644
--- a/prepare_stmt.go
+++ b/prepare_stmt.go
@@ -45,7 +45,12 @@ func (db *PreparedStmtDB) Close() {
 }
 
 func (db *PreparedStmtDB) Reset() {
-	db.Close()
+	db.Mux.Lock()
+	defer db.Mux.Unlock()
+	for _, stmt := range db.Stmts {
+		go stmt.Close()
+	}
+
 	db.PreparedSQL = make([]string, 0, 100)
 	db.Stmts = map[string](*Stmt){}
 }