golang 并发

作者: bigtom | 来源:发表于2016-07-22 21:42 被阅读910次

    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!

    相关文章

      网友评论

        本文标题:golang 并发

        本文链接:https://www.haomeiwen.com/subject/yfiijttx.html