{ broadCastChan := make(chan struct{}, 1) stopChan := make(chan struct{}, len(workers)) var wg sync.WaitGroup for _, worker := range workers { wg.Add(1) go func(worker *Worker) { defer wg.Done() err := worker.Work(broadCastChan) log.Printl…