码迷,mamicode.com
首页 > 编程语言 > 详细

Go语言的并发和并行

时间:2014-09-26 00:06:57      阅读:260      评论:0      收藏:0      [点我收藏+]

标签:style   blog   http   color   os   使用   for   数据   sp   

  不知道你有没有注意到,这段代码如果我跑在两个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为什么是这样输出的呢?

 

关于并行和并发,下面这张图说明:

bubuko.com,布布扣

 

  • 两个队列,一个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

}

总结

我们从例子中可以看到,默认的, 所有goroutine会在一个原生线程里跑

在同一个原生线程里,如果当前goroutine不发生阻塞,它是不会让出CPU时间给其他同线程的goroutines的,这是Go运行时对goroutine的调度,我们也可以使用runtime包来手工调度。

当一个goroutine发生阻塞,Go会自动地把与该goroutine处于同一系统线程的其他goroutines转移到另一个系统线程上去,以使这些goroutines不阻塞

 

Go语言的并发和并行

标签:style   blog   http   color   os   使用   for   数据   sp   

原文地址:http://www.cnblogs.com/hupengcool/p/3993823.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!