gistfile1.txt

func KojiListLatestBuilds(repo string) []string {
        wg := sync.WaitGroup{}
        queue := make(chan string)

        doWork := func(i int, pkg string) string {
                build := KojiLatestBuild(repo, pkg)
                fmt.Printf("Worker %d working on %s - %s\n", i, pkg, build)
                return build
        }

        for worker := 0; worker < Limit; worker++ {
                wg.Add(1)

                go func(worker int) {
                        defer wg.Done()
                        for work := range queue {
                                doWork(worker, work) // blocking wait for work
                        }
                }(worker)
        }

        pkgs := KojiListPackages(repo)
        for _, pkg := range pkgs {
                queue <- pkg
        }

        close(queue)
        wg.Wait()

        return []string{}
}