gistfile1.txt

const Limit = 50

func doKojiLatestBuild(worker int, repo string, pkg string, results chan<- string) {
        build := KojiLatestBuild(repo, pkg)
        fmt.Println(worker, repo, pkg, ">>", build)
        results <- build
}

func KojiListLatestBuilds(repo string) []string {
        pkgs := KojiListPackages(repo)

        queue := make(chan string)
        results := make(chan string, len(pkgs))

        // limit worker
        for worker := 0; worker < Limit; worker++ {
                go func(worker int) {
                        for work := range queue {
                                doKojiLatestBuild(worker, repo, work, results) // blocking wait for work
                        }
                }(worker)
        }
        for _, pkg := range pkgs {
                queue <- pkg
        }

        close(queue)

        builds := []string{}
        for i := 1; i <= len(pkgs); i++ {
                builds = append(builds, <-results)
        }
        return builds
}

gistfile2.txt

const Limit = 50

func doKojiLatestBuild(worker int, repo string, pkg string, results chan<- string) {
        build := KojiLatestBuild(repo, pkg)
        fmt.Println(worker, repo, pkg, ">>", build)
        results <- build
}

func KojiListLatestBuilds(repo string) []string {
        pkgs := KojiListPackages(repo)

        queue := make(chan string)
        results := make(chan string, len(pkgs))

        // limit worker
        for worker := 0; worker < Limit; worker++ {
                go func(worker int) {
                        for work := range queue {
                                doKojiLatestBuild(worker, repo, work, results) // blocking wait for work
                        }
                }(worker)
        }
        for _, pkg := range pkgs {
                queue <- pkg
        }

        close(queue)

        builds := []string{}
        for i := 1; i <= len(pkgs); i++ {
                builds = append(builds, <-results)
        }
        return builds
}