GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-06-08 01:09:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: unittest

Browse Source
This commit is contained in:
徐聪
2022-07-14 15:24:43 +08:00
parent ef71d61413
commit 1a5523bc2e
2 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hrp/internal/boomer/runner.go
View File

@@ -383,7 +383,6 @@ func (r *runner) spawnWorkers(spawnCount int64, spawnRate float64, quit chan boo
// spawn workers with rate limit // spawn workers with rate limit
sleepTime := time.Duration(1000000/r.controller.getSpawnRate()) * time.Microsecond sleepTime := time.Duration(1000000/r.controller.getSpawnRate()) * time.Microsecond
time.Sleep(sleepTime) time.Sleep(sleepTime)
// loop count per worker // loop count per worker
var workerLoop *Loop var workerLoop *Loop
if r.loop != nil { if r.loop != nil {

2
hrp/internal/boomer/runner_test.go
View File

@@ -193,7 +193,7 @@ func TestSpawnWorkersWithManyTasks(t *testing.T) {
runner.setTasks(tasks) runner.setTasks(tasks)
runner.client = newClient("localhost", 5557, runner.nodeID) runner.client = newClient("localhost", 5557, runner.nodeID)
const numToSpawn int64 = 30 const numToSpawn int64 = 20
go runner.spawnWorkers(numToSpawn, float64(numToSpawn), runner.stopChan, runner.spawnComplete) go runner.spawnWorkers(numToSpawn, float64(numToSpawn), runner.stopChan, runner.spawnComplete)
time.Sleep(3 * time.Second) time.Sleep(3 * time.Second)