saltedcoffii/ALHP.GO
1
0
Fork 0
forked from ALHP/ALHP.GO
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added waitgroup

Browse Source
This commit is contained in:
Giovanni Harting
2022-08-13 21:55:17 +02:00
parent 87cf1e5631
commit 8ff928d7fa
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
main.go
View File

@@ -327,12 +327,14 @@ func (b *BuildManager) refreshSRCINFOs(ctx context.Context, path string) error {
step := int(float32(len(pkgBuilds)) / float32(runtime.NumCPU())) step := int(float32(len(pkgBuilds)) / float32(runtime.NumCPU()))
cur := 0 cur := 0
wg := sync.WaitGroup{}
for i := 0; i < runtime.NumCPU(); i++ { for i := 0; i < runtime.NumCPU(); i++ {
if cur+step > len(pkgBuilds) { if cur+step > len(pkgBuilds) {
step -= cur + step - len(pkgBuilds) step -= cur + step - len(pkgBuilds)
} }
wg.Add(1)
go func(pkgBuilds []string) { go func(pkgBuilds []string) {
defer wg.Done()
for _, pkgbuild := range pkgBuilds { for _, pkgbuild := range pkgBuilds {
mPkgbuild := PKGBUILD(pkgbuild) mPkgbuild := PKGBUILD(pkgbuild)
if mPkgbuild.FullRepo() == "trunk" || !Contains(conf.Repos, mPkgbuild.Repo()) || containsSubStr(mPkgbuild.FullRepo(), conf.Blacklist.Repo) { if mPkgbuild.FullRepo() == "trunk" || !Contains(conf.Repos, mPkgbuild.Repo()) || containsSubStr(mPkgbuild.FullRepo(), conf.Blacklist.Repo) {
@@ -390,6 +392,8 @@ func (b *BuildManager) refreshSRCINFOs(ctx context.Context, path string) error {
cur += step cur += step
} }
wg.Wait()
return nil return nil
} }