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!

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,980评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,178评论 2 380
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,868评论 0 336
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,498评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,492评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,521评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,910评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,569评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,793评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,559评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,639评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,342评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,931评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,904评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,144评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,833评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,350评论 2 342

推荐阅读更多精彩内容

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