在睡眠时超时，但在忙等待时不超时答案

【问题标题】：Go times out on sleep but not on busy-wait在睡眠时超时，但在忙等待时不超时
【发布时间】：2014-03-08 04:57:55
【问题描述】：

在 Go 中，我可以使用 time.After 使休眠函数超时，但我不能对忙于等待（或工作）的函数执行相同操作。以下代码在一秒后返回timed out，然后挂起。

package main

import (
        "fmt"
        "time"
)

func main() {
        sleepChan := make(chan int)
        go sleep(sleepChan)
        select {
        case sleepResult := <-sleepChan:
                fmt.Println(sleepResult)
        case <-time.After(time.Second):
                fmt.Println("timed out")
        }

        busyChan := make(chan int)
        go busyWait(busyChan)
        select {
        case busyResult := <-busyChan:
                fmt.Println(busyResult)
        case <-time.After(time.Second):
                fmt.Println("timed out")
        }
}

func sleep(c chan<- int) {
        time.Sleep(10 * time.Second)
        c <- 0
}

func busyWait(c chan<- int) {
        for {
        }
        c <- 0
}

为什么在第二种情况下超时不触发，我需要使用什么替代方法来中断正在工作的 goroutine？

【问题讨论】：

for{} 在任何软件中几乎都不是您想要的。你试过有效的东西吗？
我同意。这似乎不是一个非常有用的问题，因为永远不需要像这样的紧密繁忙循环。任何允许与 goroutine 调度程序交互的东西（特别是使用通道和计时器）都将允许它交换，因此您提出的问题将不会真正存在。
好问题。它最初是一个素数检查，但我用忙碌的等待代替它以简化问题。

标签： concurrency go timeout thread-sleep busy-waiting

【解决方案1】：

for {} 语句是一个无限循环，它独占单个处理器。将 runtime.GOMAXPROCS 设置为 2 或更多以允许计时器运行。

例如，

package main

import (
    "fmt"
    "runtime"
    "time"
)

func main() {
    fmt.Println(runtime.GOMAXPROCS(0))
    runtime.GOMAXPROCS(runtime.NumCPU())
    fmt.Println(runtime.GOMAXPROCS(0))
    sleepChan := make(chan int)
    go sleep(sleepChan)
    select {
    case sleepResult := <-sleepChan:
        fmt.Println(sleepResult)
    case <-time.After(time.Second):
        fmt.Println("timed out")
    }

    busyChan := make(chan int)
    go busyWait(busyChan)
    select {
    case busyResult := <-busyChan:
        fmt.Println(busyResult)
    case <-time.After(time.Second):
        fmt.Println("timed out")
    }
}

func sleep(c chan<- int) {
    time.Sleep(10 * time.Second)
    c <- 0
}

func busyWait(c chan<- int) {
    for {
    }
    c <- 0
}

输出（4 CPU 处理器）：

1
4
timed out
timed out

【讨论】：

谢谢！我误以为循环最终会屈服于调度程序。显然，如果不调用 runtime.Gosched()，就不会发生这种情况。