go-zero/core/fx/parallel.go

package fx

import "github.com/tal-tech/go-zero/core/threading"

func Parallel(fns ...func()) {
	group := threading.NewRoutineGroup()
	for _, fn := range fns {
		group.RunSafe(fn)
	}
	group.Wait()
}