In internal/pool/pool.go, the private consume function needs to handle the correct number of live goroutines to make sure performance are not degraded in case some goroutine fails the setup phase.
defer func() {
if r := recover(); r != nil {
p.logger.Debug("Recovered in consume ", ID.String(), " ", r)
p.wg.Done()
return
}
}()
Description
In
internal/pool/pool.go
, the privateconsume
function needs to handle the correct number of live goroutines to make sure performance are not degraded in case some goroutine fails the setup phase.