AcquireAllIdle immediately returns nil if pool is closed
This commit is contained in:
@@ -361,6 +361,10 @@ func (p *Pool) Acquire(ctx context.Context) (*Resource, error) {
|
|||||||
// statistics.
|
// statistics.
|
||||||
func (p *Pool) AcquireAllIdle() []*Resource {
|
func (p *Pool) AcquireAllIdle() []*Resource {
|
||||||
p.cond.L.Lock()
|
p.cond.L.Lock()
|
||||||
|
if p.closed {
|
||||||
|
p.cond.L.Unlock()
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
for _, res := range p.idleResources {
|
for _, res := range p.idleResources {
|
||||||
res.status = resourceStatusAcquired
|
res.status = resourceStatusAcquired
|
||||||
|
|||||||
Reference in New Issue
Block a user