package mainimport (    "fmt"    "runtime"    "sync"    "time")// Possible worker states.const (    Stopped = 0    Paused  = 1    Running = 2)// Maximum number of workers.const WorkerCount = 1000func main() {    // Launch workers.    var wg sync.WaitGroup    wg.Add(WorkerCount + 1)    workers := make([]chan int, WorkerCount)    for i := range workers {        workers[i] = make(chan int)        go func(i int) {            worker(i, workers[i])            wg.Done()        }(i)    }    // Launch controller routine.    go func() {        controller(workers)        wg.Done()    }()    // Wait for all goroutines to finish.    wg.Wait()}func worker(id int, ws <-chan int) {    state := Paused // Begin in the paused state.    for {        select {        case state = <-ws:            switch state {            case Stopped:                fmt.Printf("Worker %d: Stopped\n", id)                return            case Running:                fmt.Printf("Worker %d: Running\n", id)            case Paused:                fmt.Printf("Worker %d: Paused\n", id)            }        default:            // We use runtime.Gosched() to prevent a deadlock in this case.            // It will not be needed of work is performed here which yields            // to the scheduler.            runtime.Gosched()            if state == Paused {                break            }            // Do actual work here.        }    }}但是這段代碼也有一個問題：如果你想在退出workers時刪除一個工作通道，worker()就會發(fā)生死鎖。如果你close(workers[i])，下次控制器寫入它會導(dǎo)致恐慌，因為 go 無法寫入關(guān)閉的通道。如果你使用一些互斥鎖來保護它，那么它會被卡住，workers[i] <- Running因為worker它沒有從通道讀取任何東西，寫操作會被阻塞，互斥鎖會導(dǎo)致死鎖。作為變通方法，您還可以為通道提供更大的緩沖區(qū)，但這還不夠好。所以我認(rèn)為解決這個問題的最好方法是worker()退出時關(guān)閉通道，如果控制器發(fā)現(xiàn)通道關(guān)閉，它會跳過它并且什么也不做。但是在這種情況下，我找不到如何檢查通道是否已關(guān)閉。如果我嘗試讀取控制器中的通道，則控制器可能被阻塞。所以我現(xiàn)在很困惑。PS：恢復(fù)引發(fā)的恐慌是我嘗試過的，但它會關(guān)閉引發(fā)恐慌的 goroutine。在這種情況下，它將是控制器，所以它沒有用。盡管如此，我認(rèn)為 Go 團隊在下一個版本的 Go 中實現(xiàn)這個功能是有用的。