save

pool.go

@@ -27,6 +27,8 @@ type Pool struct {
 
 	slavesIter      *atomic.Int64
 	slavesAsyncIter *atomic.Int64
+
+	stop bool
 }
 
 func New() *Pool {
@@ -188,9 +190,15 @@ func (d *Pool) setNotAliveConn(conn *conn) {
 	}
 }
 
-func (d *Pool) Test() {
+func (d *Pool) Start() {
+	d.stop = false
+
 	go func() {
 		for {
+			if d.stop {
+				return
+			}
+
 			for i, q := range d.notAliveConns {
 				if err := d.ping(q); err == nil {
 					d.mu.Lock()
@@ -212,6 +220,10 @@ func (d *Pool) Test() {
 	}()
 }
 
+func (d *Pool) Stop() {
+	d.stop = true
+}
+
 func (d *Pool) prepare(sql string, param map[string]any) string {
 	for n, t := range param {
 		switch t.(type) {