Переглянути джерело

lock mu when checking if the pool is closed

Chris Bannister 10 роки тому
батько
коміт
edf935ca8e
1 змінених файлів з 4 додано та 1 видалено
  1. 4 1
      connectionpool.go

+ 4 - 1
connectionpool.go

@@ -291,7 +291,10 @@ func (c *SimplePool) HandleError(conn *Conn, err error, closed bool) {
 		return
 	}
 	c.removeConn(conn)
-	if !c.quit {
+	c.mu.Lock()
+	poolClosed := c.quit
+	c.mu.Unlock()
+	if !poolClosed {
 		go c.fillPool() // top off pool.
 	}
 }