forked from gitea/act_runner
552dbcdda9
Add copyright header Co-authored-by: sillyguodong <gedong_1994@163.com> Reviewed-on: gitea/act_runner#29 Reviewed-by: Jason Song <i@wolfogre.com> Reviewed-by: Zettat123 <zettat123@noreply.gitea.io> Co-authored-by: sillyguodong <sillyguodong@noreply.gitea.io> Co-committed-by: sillyguodong <sillyguodong@noreply.gitea.io>
28 lines
416 B
Go
28 lines
416 B
Go
// Copyright 2022 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package poller
|
|
|
|
import "sync"
|
|
|
|
type routineGroup struct {
|
|
waitGroup sync.WaitGroup
|
|
}
|
|
|
|
func newRoutineGroup() *routineGroup {
|
|
return new(routineGroup)
|
|
}
|
|
|
|
func (g *routineGroup) Run(fn func()) {
|
|
g.waitGroup.Add(1)
|
|
|
|
go func() {
|
|
defer g.waitGroup.Done()
|
|
fn()
|
|
}()
|
|
}
|
|
|
|
func (g *routineGroup) Wait() {
|
|
g.waitGroup.Wait()
|
|
}
|