Method Run

pkg/queue/thread.go:13–20

(fn func())

}

func (g *routineGroup) Run(fn func()) {
	g.waitGroup.Add(1)

	go func() {
		defer g.waitGroup.Done()
		fn()
	}()
}

func (g *routineGroup) Wait() {
	g.waitGroup.Wait()