Go语言的并发和并行

原作者: [db:作者] 来自: [db:来源] 收藏邀请

　　不知道你有没有注意到，这段代码如果我跑在两个goroutines里面的话:

package main

import (
    "fmt"
)

func loop(done chan bool) {
    for i := 0; i < 10; i++ {
        fmt.Print(i)
    }
    done <- true
}

func main() {
    done := make(chan bool)
    go loop(done)
    go loop(done)

    <-done
    <-done

}

他的输出结果： 01234567890123456789

go不是会新起一个goroutine来运行loop函数吗。以前我们用线程去做类似任务的时候，系统的线程会抢占式地输出，表现出来的是乱序地输出。而goroutine为什么是这样输出的呢？

关于并行和并发，下面这张图说明：

两个队列，一个Coffee机器，那是并发
两个队列，两个Coffee机器，那是并行

默认地， Go所有的goroutines只能在一个线程里跑。

如果当前goroutine不发生阻塞，它是不会让出CPU给其他goroutine的, 所以上面的例子的输出会是一个一个goroutine进行的

真正的并行

为了达到真正的并行，runtime.GOMAXPROCS(2)试试看

package main

import (
    "fmt"
    "runtime"
)

func loop(done chan bool) {
    for i := 0; i < 100; i++ {
        fmt.Printf("%d ", i)
    }
    done <- true
}

func main() {
    runtime.GOMAXPROCS(2)
    done := make(chan bool)
    go loop(done)
    go loop(done)

    <-done
    <-done

}

这下会看到两个goroutine会抢占式地输出数据了。我们还可以这样显式地让出CPU时间：

package main

import (
    "fmt"
    "runtime"
)

func loop(done chan bool) {
    for i := 0; i < 100; i++ {
        fmt.Printf("%d ", i)
        runtime.Gosched()  //// 显式地让出CPU时间给其他goroutine
    }
    done <- true
}

func main() {
    // runtime.GOMAXPROCS(2)
    done := make(chan bool)
    go loop(done)
    go loop(done)

    <-done
    <-done

}