我的消費(fèi)者（從 運(yùn)行）支持上下文取消和通過(guò)語(yǔ)句main從通道讀取。case我可以使用上下文關(guān)閉消費(fèi)者，效果很好。但是，當(dāng)我在一個(gè)案例語(yǔ)句中生成多個(gè)工作人員時(shí)，每個(gè)工作人員都會(huì)從 獲得相同的工作（消息）jobsChan，這不是我想要的：func (app *App) consumer() {    for {        select {        case <-app.ctx.Done():            app.infoLog.Print("Caught SIGINT, stopping.")            app.wg.Wait()            app.doneChan <- struct{}{} # main uses this channel to block itself until all goroutines are stopped            app.infoLog.Print("Shutting down the consumer...")            return        case job := <-app.jobsChan:            // PROBLEM here: wrong, each worker is given the same job            for workerNumber := 0; workerNumber < app.config.workers; workerNumber++ {                app.wg.Add(1)                go app.workerFunc(workerNumber, job)            }        }    }}func (app *App) workerFunc(id int, job Job) {    defer app.wg.Done()        ... actual worker code here ...}如何重寫(xiě)此代碼以便我可以保留select頻道app.ctx.Done并同時(shí)生成工人，以便每個(gè)工人從頻道中選擇下一條消息作為作業(yè)？我需要繼續(xù)for/select監(jiān)聽(tīng)ctx取消，但同時(shí)我需要生成 X 工作人員來(lái)讀取來(lái)自jobsChan消費(fèi)者的消息。這可能嗎？想到的唯一選擇是將 channel 直接傳遞給 spawnedworkerFunc并for job := range app.jobsChan在workerFunc. 但隨后case job := <-app.jobsChan:消費(fèi)者的整體變得毫無(wú)意義，我不知道如何重寫(xiě)它。澄清一下：當(dāng)我運(yùn)行應(yīng)用程序時(shí)，我希望每個(gè)工作人員都有一個(gè)新的工作 id 從jobsChan- 但他們都處理相同的，例如 1，然后他們都處理下一個(gè)，例如 2#wrongWorker 0: start processing item 1Worker 2: start processing item 1Worker 1: start processing item 1