From b6eaea118bdeadff62fc6e0d519d4287cc92d62c Mon Sep 17 00:00:00 2001
From: Andy Pan <panjf2000@gmail.com>
Date: Tue, 20 Dec 2022 22:09:35 +0800
Subject: [PATCH] opt: refine some code

---
 pool.go      | 8 +++++---
 pool_func.go | 8 +++++---
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/pool.go b/pool.go
index 41fd61d..c7a290c 100644
--- a/pool.go
+++ b/pool.go
@@ -137,12 +137,14 @@ func (p *Pool) ticktock(ctx context.Context) {
 }
 
 func (p *Pool) goPurge() {
+	if p.options.DisablePurge {
+		return
+	}
+
 	// Start a goroutine to clean up expired workers periodically.
 	var ctx context.Context
 	ctx, p.stopPurge = context.WithCancel(context.Background())
-	if !p.options.DisablePurge {
-		go p.purgeStaleWorkers(ctx)
-	}
+	go p.purgeStaleWorkers(ctx)
 }
 
 func (p *Pool) goTicktock() {
diff --git a/pool_func.go b/pool_func.go
index ec2dfd2..ba54951 100644
--- a/pool_func.go
+++ b/pool_func.go
@@ -160,12 +160,14 @@ func (p *PoolWithFunc) ticktock(ctx context.Context) {
 }
 
 func (p *PoolWithFunc) goPurge() {
+	if p.options.DisablePurge {
+		return
+	}
+
 	// Start a goroutine to clean up expired workers periodically.
 	var ctx context.Context
 	ctx, p.stopPurge = context.WithCancel(context.Background())
-	if !p.options.DisablePurge {
-		go p.purgeStaleWorkers(ctx)
-	}
+	go p.purgeStaleWorkers(ctx)
 }
 
 func (p *PoolWithFunc) goTicktock() {