去例行阻止其他人

Question

以下代码永远运行，而不是在开始后一秒停止。带有无限循环的 go 例程似乎阻止了另一个发送到超时通道。这是正常的吗？

 func main(){

   timeout:=make(chan int)

   go func(){

      time.SLeep(time.Second)

      timeout<-1

    }()

    res:=make(chan int)

    go func(){

        for{

        }

        res<-1

    }()

    select{

        case<-timeout:

            fmt.Println("timeout")

        case<-res:

            fmt.Println("res")

    }

}

Answer 1

简短的回答：是的。当前的实现使用 goroutines 之间的协作调度。这意味着一个 goroutine 必须将执行移交给调度程序，以便另一个 goroutine 运行。将来有希望使用不会有此限制的抢占式调度程序。当以下任何一种情况发生时，Goroutines 将让给调度程序（可能不是一个完整的列表）：无缓冲的 chan 发送/接收系统调用（包括文件/网络读写）内存分配time.Sleep() 被调用runtime.Gosched() 被调用当您有一个非常处理器密集的循环时，最后一个允许您手动让步给调度程序。我从来没有发现需要它，因为我使用的几乎所有东西都有足够的通信（通道或系统 io），我的程序永远不会卡住。还有 GOMAXPROCS，您可能会听到它作为解决方案。虽然它可以通过将所有 goroutine 放在不同的线程中来运行它们，但垃圾收集器最终会尝试运行并停止世界。当它停止世界时，不允许任何 goroutines 运行，如果高 cpu goroutines 永远不会让步，GC 将永远阻塞 goroutines 但永远不会运行。