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

panjf2000 · Jun 17, 2024 · 0d650f5 · 0d650f5
1 parent ee5a718
commit 0d650f5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/ants.go b/ants.go
@@ -96,7 +96,10 @@ var (
 	defaultAntsPool, _ = NewPool(DefaultAntsPoolSize)
 )
 
-const nowTimeUpdateInterval = 500 * time.Millisecond
+const (
+	nowTimeUpdateInterval  = 500 * time.Millisecond
+	releaseTimeoutInterval = 100 * time.Millisecond
+)
 
 // Logger is used for logging formatted messages.
 type Logger interface {

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

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