mirror of
https://github.com/TeaOSLab/EdgeNode.git
synced 2025-11-04 16:00:25 +08:00
31 lines
559 B
Go
31 lines
559 B
Go
|
// Copyright 2023 GoEdge CDN goedge.cdn@gmail.com. All rights reserved. Official site: https://goedge.cn .
|
||
|
|
|
||
|
|
package goman_test
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/TeaOSLab/EdgeNode/internal/goman"
|
||
|
|
"runtime"
|
||
|
|
"testing"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestNewTaskGroup(t *testing.T) {
|
||
|
|
var group = goman.NewTaskGroup()
|
||
|
|
var m = map[int]bool{}
|
||
|
|
|
||
|
|
for i := 0; i < runtime.NumCPU()*2; i++ {
|
||
|
|
var index = i
|
||
|
|
group.Run(func() {
|
||
|
|
t.Log("task", index)
|
||
|
|
|
||
|
|
group.Lock()
|
||
|
|
_, ok := m[index]
|
||
|
|
if ok {
|
||
|
|
t.Error("duplicated:", index)
|
||
|
|
}
|
||
|
|
m[index] = true
|
||
|
|
group.Unlock()
|
||
|
|
})
|
||
|
|
}
|
||
|
|
group.Wait()
|
||
|
|
}
|