golang 并发

Do not communicate by sharing memory; instead, share memory by communicating.

nodejs的异步io模型,python的协程和多进程,java的multi-thread,说到底,这些模型都是为了实现程序的并行。我相信,大家在学习golang前,肯定都做了一些调研,也肯定看到了很多人在称赞golang的时候提到了golang在并行上的优点。

什么是并发和并行

并发就是,你有二十个女朋友,然后他们同时在和你聊微信。而并行就是,你实在聊不过来了,于是你雇了5个人帮你同时和你的女朋友们聊天。

goroutine

一开始你只找到了一个好朋友肯帮你。你的朋友照着模板敲一些情话,你负责填入女孩的名字。

func sayName() {
    girls := []string { "amy","rose","lily","judy","penny"}
    for i := 0; i < 5; i++ {
        fmt.Print(girls[i] + "\n")
        runtime.Gosched() 
    }
}

func sayLove(){
    for i := 0; i<5; i++ {
        fmt.Print("I love you,")
        runtime.Gosched()
    }
}

func main() {
    go sayName()
    sayLove()
}

//output:
//I love you,amy
//I love you,rose
//I love you,lily
//I love you,judy
//I love you,penny

这样你就同时和5个女孩聊上了,这里,你的哥们占据着主线程,不停的说"Ilove you",而你则占据着一个goroutine(可以理解为线程),不停的输入女孩的名字。这里的runtime.Gosched()类似于python里的yeild,用于交出cpu,等之后再回来计算,就是说,你的哥们每次敲完"i love you",就把键盘交给你,然后你开始敲女孩的名字,等你敲完,你再把键盘交给你哥们。看上去天衣无缝吧,但是这么搞很危险啊。万一你的哥们动作慢了几拍,你却以为他已经敲了,又接过键盘(cpu),连打了几个女孩的名字,你这是要扑街啊。

channel

为了安全起见,还是多找几个朋友(goroutine)吧,没来一个女朋友的聊天,你就找一个goroutine盯着,然后通过一个管道告诉你应该怎么回答。

func sayName(s string, c chan string) {
    c <- "I love you," + s   //发送值
}

func main() {
    girls := []string { "amy","rose","lily","judy","penny"}
    c := make(chan string)
    for _,g := range girls{
        go sayName(g, c)
    }
    x1,x2,x3,x4,x5 := <- c, <- c, <- c, <- c, <- c //接收值
    fmt.Println(x1)
    fmt.Println(x2)
    fmt.Println(x3)
    fmt.Println(x4)
    fmt.Println(x5)
}

这里我们使用了channel,这是go中用来在goroutine之间进行数据通信的一种通信机制。说白了,我们可以用它来发送和接受值这些值。我们使用make 创建channel,并声明发送到channel的值的类型。另外需要注意的是,channel的收发默认是阻塞的,也就是说在我们接收值得时候,如果channel还没有返回,程序会阻塞在这里。

select

等等,有细心的小伙伴发现了问题,这小子胆儿够肥啊,不怕把发给amy的消息发给lily啊。你用一个channel不是等于群聊了么(虽然这里的channel并不是用来在和女朋友之间通信的)。okok,为了安全,给每个女朋友建一个channel。

func sayName(amy,lily,judy chan int) {
  for {
    //不停监听每个channel的消息,对不同的女孩说不同的话
    //select用起来的感觉和switch差不多
    select {
    case <- amy :
      fmt.Println("I love you amy")
    case <- lily :
      fmt.Println("I love you lily")
    case <- judy :
      fmt.Println("I love you judy")
    }
  }
}

func main(){
  //给每个女孩都建一个channel
  amy := make(chan int)
  lily := make(chan int)
  judy := make(chan int)
  //跑一个goroutine专门用来监听每个女孩的channel
  go sayName(amy, lily, judy)
  amy <- 0
  lily <- 0
  judy <- 0
}

写了这么多,终于到了点明主旨的时候了,愿世间没有渣男。Peace!

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Goroutines 模型:和其他goroutine在共享的地址空间中并发执行的函数 资源消耗: 初始时非常小的栈...
    大漠狼道阅读 1,301评论 0 8
  • 控制并发有三种种经典的方式,一种是通过channel通知实现并发控制 一种是WaitGroup,另外一种就是Con...
    wiseAaron阅读 10,737评论 4 34
  • 并发concurrency -很多人都是冲着Go 大肆宣扬的高并发而忍不住跃跃欲试,但其实从源码的解析来看,gor...
    战神汤姆阅读 329评论 0 0
  • 演员表 马恩 // main goroutine, 每个go程序至少有一个goroutine 高老丁1 // 一个...
    calvinxiao阅读 714评论 1 2
  • 正好刚从南方回来 也发现了一个特点:就是南方可以说是处处都支持微信和支付宝 ,而北方就有好多地方只支持微信 让一贯...
    sungchiangtao阅读 224评论 0 0