Google Go Goroutine的中断模式（速度问题）

Z时代
2024-01-10
分类：问答

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

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

但是，如果我选择使用case

<-time.After(100*time.Microsecond):，则计数器j在一秒内最多只能增加60个左右，而不是10,000个。

实际上，无论我输入什么值time.After()，在select声明中我只能得到大约60Hz的频率。

为什么？

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"
        }
    }
}