一 Golang对协程的支持

Go语言从语言层面原生提供了协程支持,即 goroutine,执行goroutine只需极少的栈内存(大概是4~5KB),所以Go可以轻松的运行多个并发任务。

Go中以关键字 go 开启协程:

func say(s string) {
    for i := 0; i < 3; i++ {
        fmt.Println(s)
    }
}

func main() {
    go say("Go")                        // 以协程方式执行say函数
    say("noGo")                            // 以普通方式执行say函数
    time.Sleep(5 * time.Second)         // 睡眠5秒:防止协程未执行完毕,主程序退出
}

上述的程序的打印结果并不是按照顺序的,因为go关键字开启了协程,两个say函数并不是在一个控制流中!

二 goroutine使用案例

2.1 同时执行两件事

func running() {
    var times int
    for {
        times++
        fmt.Println("tick:", times)
        time.Sleep(time.Second)
    }
}

func main() {
    go running()
    var input string
    fmt.Scanln(&input)
}

命令行会不断地输出 tick,同时可以使用 fmt.Scanln() 接受用户输入。两个环节可以同时进行,直到按 Enter键时将输入的内容写入 input变量中井返回, 整个程序终止。

2.2 一道基础面试题

示例一:

for i := 1; i <= 10; i++ {
    go func(){
        fmt.Println(i)        // 全部打印11:因为开启协程也会耗时,协程没有准备好,循环已经走完
    }()
}
time.Sleep(time.Second)

示例二:

    for i := 1; i <= 10; i++ {
        go func(i int){
            fmt.Println(i)        // 打印无规律数字
        }(i)
    }
    time.Sleep(time.Second)

三 常用API

3.1 GOMAXPROCS() 多核利用

goroutine相关API位于 runtime 包。

如果Go程序要运行在多核上,则可以如下操作,此时可以实现程序的并行执行:

    cpuNum := runtime.NumCPU()                //获取当前系统的CPU核心数
    runtime.GOMAXPROCS(cpuNum)                //Go中可以轻松控制使用核心数

贴士:在Go1.5之后,程序已经默认运行在多核上,无需上述设置

3.2 Gosched() 让出时间片

runtime.Gosched():用于让出CPU时间片,即让出当前协程的执行权限,调度器可以去安排其他等待的任务运行。示例如下:

func main(){
    for i := 1; i <= 10; i++ {
        go func(i int){
            if i == 5 {
                runtime.Gosched()    // 协程让出,但并不代表不执行,而是 5永远不会第一输出
            }
            fmt.Println(i)        // 打印一组无规律数字
        }(i)
    }
    time.Sleep(time.Second)
}

贴士:可以理解为接力赛跑:A跑了一段遇到了Gosched接力给B。

3.3 Goexit() 终止当前协程

runtime.Goexit():用于立即终止当前协程运行,调度器会确保所有已注册defer延迟调用被执行。

func main(){
    for i := 1; i <= 5; i++ {
        defer fmt.Println("defer ", i)
        go func(i int){
            if i == 3 {
                runtime.Goexit()
            }
            fmt.Println(i)
        }(i)
    }
    time.Sleep(time.Second)
}

输出的结果类似于:

4
2
5
1
defer  5
defer  4
defer  3
defer  2
defer  1

results matching ""

    No results matching ""