mirror
/
ants
mirror of https://github.com/panjf2000/ants.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

🎠 Do the code coverage test with multiple-cores and skip it when it is single-core

This commit is contained in:
Andy Pan 2019-01-27 12:57:53 +08:00
parent 454693c2db
commit 72bf8e2fb5
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
ants_test.go
View File

@ -51,10 +51,17 @@ const (
n = 100000 n = 100000
) )
func SkipIfNotMultiCores(t *testing.T) {
if runtime.GOMAXPROCS(0) == 1 {
t.SkipNow()
}
}
var curMem uint64 var curMem uint64
// TestAntsPoolWaitToGetWorker is used to test waiting to get worker. // TestAntsPoolWaitToGetWorker is used to test waiting to get worker.
func TestAntsPoolWaitToGetWorker(t *testing.T) { func TestAntsPoolWaitToGetWorker(t *testing.T) {
SkipIfNotMultiCores(t)
var wg sync.WaitGroup var wg sync.WaitGroup
p, _ := ants.NewPool(AntsSize) p, _ := ants.NewPool(AntsSize)
defer p.Release() defer p.Release()
@ -76,6 +83,7 @@ func TestAntsPoolWaitToGetWorker(t *testing.T) {
// TestAntsPoolWithFuncWaitToGetWorker is used to test waiting to get worker. // TestAntsPoolWithFuncWaitToGetWorker is used to test waiting to get worker.
func TestAntsPoolWithFuncWaitToGetWorker(t *testing.T) { func TestAntsPoolWithFuncWaitToGetWorker(t *testing.T) {
SkipIfNotMultiCores(t)
var wg sync.WaitGroup var wg sync.WaitGroup
p, _ := ants.NewPoolWithFunc(AntsSize, func(i interface{}) { p, _ := ants.NewPoolWithFunc(AntsSize, func(i interface{}) {
demoPoolFunc(i) demoPoolFunc(i)
@ -97,6 +105,7 @@ func TestAntsPoolWithFuncWaitToGetWorker(t *testing.T) {
// TestAntsPoolGetWorkerFromCache is used to test getting worker from sync.Pool. // TestAntsPoolGetWorkerFromCache is used to test getting worker from sync.Pool.
func TestAntsPoolGetWorkerFromCache(t *testing.T) { func TestAntsPoolGetWorkerFromCache(t *testing.T) {
SkipIfNotMultiCores(t)
p, _ := ants.NewPool(TestSize) p, _ := ants.NewPool(TestSize)
defer p.Release() defer p.Release()
@ -114,6 +123,7 @@ func TestAntsPoolGetWorkerFromCache(t *testing.T) {
// TestAntsPoolWithFuncGetWorkerFromCache is used to test getting worker from sync.Pool. // TestAntsPoolWithFuncGetWorkerFromCache is used to test getting worker from sync.Pool.
func TestAntsPoolWithFuncGetWorkerFromCache(t *testing.T) { func TestAntsPoolWithFuncGetWorkerFromCache(t *testing.T) {
SkipIfNotMultiCores(t)
dur := 10 dur := 10
p, _ := ants.NewPoolWithFunc(TestSize, demoPoolFunc) p, _ := ants.NewPoolWithFunc(TestSize, demoPoolFunc)
defer p.Release() defer p.Release()
@ -134,6 +144,7 @@ func TestAntsPoolWithFuncGetWorkerFromCache(t *testing.T) {
// Contrast between goroutines without a pool and goroutines with ants pool. // Contrast between goroutines without a pool and goroutines with ants pool.
//------------------------------------------------------------------------------------------- //-------------------------------------------------------------------------------------------
func TestNoPool(t *testing.T) { func TestNoPool(t *testing.T) {
SkipIfNotMultiCores(t)
var wg sync.WaitGroup var wg sync.WaitGroup
for i := 0; i < n; i++ { for i := 0; i < n; i++ {
wg.Add(1) wg.Add(1)
@ -151,6 +162,7 @@ func TestNoPool(t *testing.T) {
} }
func TestAntsPool(t *testing.T) { func TestAntsPool(t *testing.T) {
SkipIfNotMultiCores(t)
defer ants.Release() defer ants.Release()
var wg sync.WaitGroup var wg sync.WaitGroup
for i := 0; i < n; i++ { for i := 0; i < n; i++ {
@ -176,6 +188,7 @@ func TestAntsPool(t *testing.T) {
//------------------------------------------------------------------------------------------- //-------------------------------------------------------------------------------------------
func TestPanicHandler(t *testing.T) { func TestPanicHandler(t *testing.T) {
SkipIfNotMultiCores(t)
p0, err := ants.NewPool(10) p0, err := ants.NewPool(10)
if err != nil { if err != nil {
t.Fatalf("create new pool failed: %s", err.Error()) t.Fatalf("create new pool failed: %s", err.Error())
@ -225,6 +238,7 @@ func TestPanicHandler(t *testing.T) {
} }
func TestPoolPanicWithoutHandler(t *testing.T) { func TestPoolPanicWithoutHandler(t *testing.T) {
SkipIfNotMultiCores(t)
p0, err := ants.NewPool(10) p0, err := ants.NewPool(10)
if err != nil { if err != nil {
t.Fatalf("create new pool failed: %s", err.Error()) t.Fatalf("create new pool failed: %s", err.Error())
@ -245,6 +259,7 @@ func TestPoolPanicWithoutHandler(t *testing.T) {
} }
func TestPurge(t *testing.T) { func TestPurge(t *testing.T) {
SkipIfNotMultiCores(t)
p, err := ants.NewTimingPool(10, 1) p, err := ants.NewTimingPool(10, 1)
defer p.Release() defer p.Release()
if err != nil { if err != nil {
@ -268,6 +283,7 @@ func TestPurge(t *testing.T) {
} }
func TestRestCodeCoverage(t *testing.T) { func TestRestCodeCoverage(t *testing.T) {
SkipIfNotMultiCores(t)
_, err := ants.NewTimingPool(-1, -1) _, err := ants.NewTimingPool(-1, -1)
t.Log(err) t.Log(err)
_, err = ants.NewTimingPool(1, -1) _, err = ants.NewTimingPool(1, -1)
@ -304,3 +320,7 @@ func TestRestCodeCoverage(t *testing.T) {
p.Tune(AntsSize) p.Tune(AntsSize)
t.Logf("pool with func, after tuning capacity, capacity:%d, running:%d", p.Cap(), p.Running()) t.Logf("pool with func, after tuning capacity, capacity:%d, running:%d", p.Cap(), p.Running())
} }
func TestInSingleCore(t *testing.T) {
t.Log("workerChanCap in ants tested.")
}