TyleoDvDelaware3217/GoDoxy
1
0
Fork 0
mirror of https://github.com/yusing/godoxy.git synced 2025-05-20 12:42:34 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: update set/map parallel logic

Browse source
This commit is contained in:
yusing 2025-04-04 00:46:24 +08:00
parent 8e37627371
commit fdac2853af
3 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
internal/utils/functional/common.go Normal file
View file

@ -0,0 +1,3 @@
package functional
const minParallelSize = 2

2
internal/utils/functional/map.go
View file

@ -11,8 +11,6 @@ type Map[KT comparable, VT any] struct {
*xsync.MapOf[KT, VT] *xsync.MapOf[KT, VT]
} }
const minParallelSize = 4
func NewMapOf[KT comparable, VT any](options ...func(*xsync.MapConfig)) Map[KT, VT] { func NewMapOf[KT comparable, VT any](options ...func(*xsync.MapConfig)) Map[KT, VT] {
return Map[KT, VT]{xsync.NewMapOf[KT, VT](options...)} return Map[KT, VT]{xsync.NewMapOf[KT, VT](options...)}
} }

5
internal/utils/functional/set.go
View file

@ -45,6 +45,11 @@ func (set Set[T]) RangeAll(f func(T)) {
} }
func (set Set[T]) RangeAllParallel(f func(T)) { func (set Set[T]) RangeAllParallel(f func(T)) {
if set.Size() < minParallelSize {
set.RangeAll(f)
return
}
var wg sync.WaitGroup var wg sync.WaitGroup
set.Range(func(k T) bool { set.Range(func(k T) bool {