mirror of https://github.com/panjf2000/ants.git
optimization for go test
This commit is contained in:
parent
87b15034c5
commit
1833ff6764
39
ants_test.go
39
ants_test.go
|
@ -32,6 +32,7 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
var n = 100000
|
var n = 100000
|
||||||
|
var curMem uint64
|
||||||
|
|
||||||
func TestAntsPoolWithFunc(t *testing.T) {
|
func TestAntsPoolWithFunc(t *testing.T) {
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
|
@ -50,7 +51,24 @@ func TestAntsPoolWithFunc(t *testing.T) {
|
||||||
t.Logf("pool with func, running workers number:%d", p.Running())
|
t.Logf("pool with func, running workers number:%d", p.Running())
|
||||||
mem := runtime.MemStats{}
|
mem := runtime.MemStats{}
|
||||||
runtime.ReadMemStats(&mem)
|
runtime.ReadMemStats(&mem)
|
||||||
t.Logf("memory usage:%d", mem.TotalAlloc/GiB)
|
curMem = mem.TotalAlloc / MiB - curMem
|
||||||
|
t.Logf("memory usage:%d", curMem)
|
||||||
|
}
|
||||||
|
func TestNoPool(t *testing.T) {
|
||||||
|
var wg sync.WaitGroup
|
||||||
|
for i := 0; i < n; i++ {
|
||||||
|
wg.Add(1)
|
||||||
|
go func() {
|
||||||
|
demoFunc()
|
||||||
|
wg.Done()
|
||||||
|
}()
|
||||||
|
}
|
||||||
|
|
||||||
|
wg.Wait()
|
||||||
|
mem := runtime.MemStats{}
|
||||||
|
runtime.ReadMemStats(&mem)
|
||||||
|
curMem = mem.TotalAlloc/MiB - curMem
|
||||||
|
t.Logf("memory usage:%d MB", curMem)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAntsPool(t *testing.T) {
|
func TestAntsPool(t *testing.T) {
|
||||||
|
@ -72,23 +90,8 @@ func TestAntsPool(t *testing.T) {
|
||||||
|
|
||||||
mem := runtime.MemStats{}
|
mem := runtime.MemStats{}
|
||||||
runtime.ReadMemStats(&mem)
|
runtime.ReadMemStats(&mem)
|
||||||
t.Logf("memory usage:%d MB", mem.TotalAlloc/MiB)
|
curMem = mem.TotalAlloc/MiB - curMem
|
||||||
}
|
t.Logf("memory usage:%d MB", curMem)
|
||||||
|
|
||||||
func TestNoPool(t *testing.T) {
|
|
||||||
var wg sync.WaitGroup
|
|
||||||
for i := 0; i < n; i++ {
|
|
||||||
wg.Add(1)
|
|
||||||
go func() {
|
|
||||||
demoFunc()
|
|
||||||
wg.Done()
|
|
||||||
}()
|
|
||||||
}
|
|
||||||
|
|
||||||
wg.Wait()
|
|
||||||
mem := runtime.MemStats{}
|
|
||||||
runtime.ReadMemStats(&mem)
|
|
||||||
t.Logf("memory usage:%d MB", mem.TotalAlloc/MiB)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestCodeCov(t *testing.T) {
|
func TestCodeCov(t *testing.T) {
|
||||||
|
|
Loading…
Reference in New Issue