re
/
ants
forked from mirror/ants
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add more test

This commit is contained in:
Andy Pan 2018-07-21 19:34:15 +08:00
parent a326530368
commit 32d4903f95
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ants_benchmark_test.go
View File

@ -45,6 +45,7 @@ const (
RunTimes = 10000000
Param = 100
AntsSize = 500
TestSize = 10000
)
func demoFunc() error {

7
ants_test.go
View File

@ -28,6 +28,7 @@ import (
"testing"
"github.com/panjf2000/ants"
"time"
)
var n = 100000
@ -46,7 +47,6 @@ func TestAntsPoolWithFunc(t *testing.T) {
p.Serve(Param)
}
wg.Wait()
t.Logf("pool with func, running workers number:%d", p.Running())
mem := runtime.MemStats{}
runtime.ReadMemStats(&mem)
@ -114,17 +114,18 @@ func TestCodeCov(t *testing.T) {
p0.ReSize(AntsSize / 2)
t.Logf("pool, after resize, capacity:%d, running:%d", p0.Cap(), p0.Running())
p, _ := ants.NewPoolWithFunc(AntsSize, demoPoolFunc)
p, _ := ants.NewPoolWithFunc(TestSize, demoPoolFunc)
defer p.Serve(Param)
defer p.Release()
for i := 0; i < n; i++ {
p.Serve(Param)
}
time.Sleep(ants.DefaultCleanIntervalTime * time.Second)
t.Logf("pool with func, capacity:%d", p.Cap())
t.Logf("pool with func, running workers number:%d", p.Running())
t.Logf("pool with func, free workers number:%d", p.Free())
p.ReSize(TestSize)
p.ReSize(AntsSize)
p.ReSize(AntsSize / 2)
t.Logf("pool with func, after resize, capacity:%d, running:%d", p.Cap(), p.Running())
}