首页　>　文章列表　>　谷歌 goroutine 的中断模式（速度问题）

谷歌 goroutine 的中断模式（速度问题）

golang
180 2023-03-08

问题内容

我运行一个 goroutine 来增加一个计数器，它可以被命令行输入“tn”打断

在select语句中，如果我选择使用default:，计数器变量会j向前飞。这对我来说似乎很正常。

但是，如果我选择使用case <-time.After(100*time.Microsecond):，则计数器j在一秒钟内只加到 60 左右，而不是 10,000。

事实上，无论我输入什么值time.After()，我都只能得到大约 60Hz 的运行频率select。

为什么？

package main
import (
    "bufio"
    "fmt"
    "os"
    "strings"
    "time"
)

func main() {
    message := make(chan string)
    go check_input(message)
    work_loop(message)
}

func work_loop(message chan string) {
    //var j [][]int
    var j int
    t0:=time.Now()
Loop:
    for {
        select {
        case msg := <-message:
            if msg == "terminate" {
                //fmt.Println("end task")
                t1:=time.Now()
                fmt.Println(j)
                fmt.Println("total duration:", t1.Sub(t0))
                break Loop
            }
        case <-time.After(100 * time.Microsecond):
        //default:
            //do work here          
            j += 1
            fmt.Println(j)
            break

        }
    }
    //fmt.Println("exit work loop")
}

func check_input(msg chan string) {
    reader := bufio.NewReader(os.Stdin)
    for {
        line, err := reader.ReadString('n')

        if err != nil {
            // You may check here if err == io.EOF
            break
        }

        if strings.TrimSpace(line) == "t" {
            msg <- "terminate"
        }
    }
}