forked from mirror/ants
📝Fix the type error
This commit is contained in:
parent
9eb91a4ae0
commit
f447bf104a
|
@ -71,7 +71,7 @@ func (p *PoolWithFunc) periodicallyPurge() {
|
||||||
heartbeat := time.NewTicker(p.expiryDuration)
|
heartbeat := time.NewTicker(p.expiryDuration)
|
||||||
defer heartbeat.Stop()
|
defer heartbeat.Stop()
|
||||||
|
|
||||||
var expiredWorkers []*Worker
|
var expiredWorkers []*WorkerWithFunc
|
||||||
for range heartbeat.C {
|
for range heartbeat.C {
|
||||||
if CLOSED == atomic.LoadInt32(&p.release) {
|
if CLOSED == atomic.LoadInt32(&p.release) {
|
||||||
break
|
break
|
||||||
|
|
Loading…
Reference in New Issue