bingyi/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf synced 2026-07-06 05:42:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Improve grpool unit testing.

Browse Source
This commit is contained in:
hailaz
2019-06-24 15:01:12 +08:00
parent 2b02f7e210
commit 38ad5d457b
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
g/os/grpool/grpool_unit_test.go
View File

@ -9,12 +9,13 @@
package grpool_test
import (
"github.com/gogf/gf/g/container/garray"
"github.com/gogf/gf/g/os/grpool"
"github.com/gogf/gf/g/test/gtest"
"sync"
"testing"
"time"
"github.com/gogf/gf/g/container/garray"
"github.com/gogf/gf/g/os/grpool"
"github.com/gogf/gf/g/test/gtest"
)
func Test_Basic(t *testing.T) {
@ -30,7 +31,10 @@ func Test_Basic(t *testing.T) {
})
}
wg.Wait()
time.Sleep(50 * time.Millisecond)
gtest.Assert(array.Len(), size)
gtest.Assert(grpool.Jobs(), 0)
gtest.Assert(grpool.Size(), 0)
})
}
@ -75,6 +79,7 @@ func Test_Limit3(t *testing.T) {
array := garray.NewArray()
size := 1000
pool := grpool.New(100)
gtest.Assert(pool.Cap(), 100)
for i := 0; i < size; i++ {
pool.Add(func() {
array.Append(1)
@ -90,5 +95,8 @@ func Test_Limit3(t *testing.T) {
gtest.Assert(pool.Size(), 0)
gtest.Assert(pool.Jobs(), 900)
gtest.Assert(array.Len(), 100)
gtest.Assert(pool.IsClosed(), true)
gtest.AssertNE(pool.Add(func() {}), nil)
})
}