forsakenfirer/ants
1
0
Fork 0
mirror of https://github.com/panjf2000/ants.git synced 2025-12-16 09:51:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

opt: increase the interval of waiting in ReleaseTimeout() (#325)

Browse Source
This commit is contained in:
Andy Pan 2024-06-17 18:21:01 +08:00 committed by GitHub
parent ee5a7183d9
commit 0d650f5c1e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ants.go
View File

@ -96,7 +96,10 @@ var (
defaultAntsPool, _ = NewPool(DefaultAntsPoolSize) defaultAntsPool, _ = NewPool(DefaultAntsPoolSize)
) )
const nowTimeUpdateInterval = 500 * time.Millisecond const (
nowTimeUpdateInterval = 500 * time.Millisecond
releaseTimeoutInterval = 100 * time.Millisecond
)
// Logger is used for logging formatted messages. // Logger is used for logging formatted messages.
type Logger interface { type Logger interface {

2
pool.go
View File

@ -306,7 +306,7 @@ func (p *Pool) ReleaseTimeout(timeout time.Duration) error {
atomic.LoadInt32(&p.ticktockDone) == 1 { atomic.LoadInt32(&p.ticktockDone) == 1 {
return nil return nil
} }
time.Sleep(10 * time.Millisecond) time.Sleep(releaseTimeoutInterval)
} }
return ErrTimeout return ErrTimeout
} }

2
pool_func.go
View File

@ -311,7 +311,7 @@ func (p *PoolWithFunc) ReleaseTimeout(timeout time.Duration) error {
atomic.LoadInt32(&p.ticktockDone) == 1 { atomic.LoadInt32(&p.ticktockDone) == 1 {
return nil return nil
} }
time.Sleep(10 * time.Millisecond) time.Sleep(releaseTimeoutInterval)
} }
return ErrTimeout return ErrTimeout
} }