Improve workerJamDuration mechanism

johnteee · johnteee · commit 04d84d989fc3 · 2022-05-19T14:20:03.000+08:00
diff --git a/worker/pool.go b/worker/pool.go
@@ -125,7 +125,7 @@ func (workerPoolSelf *DefaultWorkerPool) trySpawn() {
 	// Avoid Jam if (now - lastAliveTime) is over workerJamDuration
 	if time.Now().Sub(workerPoolSelf.lastAliveTime) > workerPoolSelf.workerJamDuration &&
 		workerPoolSelf.workerCount >= expectedWorkerCount {
-		expectedWorkerCount++
+		expectedWorkerCount = workerPoolSelf.workerCount + 1
 	}
 	workerPoolSelf.lock.RUnlock()
 

Original file line number	Diff line number	Diff line change
`@@ -125,7 +125,7 @@ func (workerPoolSelf *DefaultWorkerPool) trySpawn() {`
`125`	`125`	`// Avoid Jam if (now - lastAliveTime) is over workerJamDuration`
`126`	`126`	`if time.Now().Sub(workerPoolSelf.lastAliveTime) > workerPoolSelf.workerJamDuration &&`
`127`	`127`	`workerPoolSelf.workerCount >= expectedWorkerCount {`
`128`		`- expectedWorkerCount++`
	`128`	`+ expectedWorkerCount = workerPoolSelf.workerCount + 1`
`129`	`129`	`}`
`130`	`130`	`workerPoolSelf.lock.RUnlock()`
`131`	`131`