golang基础--Gocurrency并发

failymao · · 698 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

  • goroutine只是由官方实现的超级"线程池"而已,每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。

  • 并发不是并行(多CPU): Concurrency Is Not Parallelism

  • 并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。
    • 通过go关键字实现多线程
    package main
    import (
        "fmt"
        "time"
    )
    
    func Go() {
        fmt.Println("1234...") 
    
    }
    
    func main() {
        go Go()                //go关键字构成多线程
        time.Sleep(2 * time.Second) //主程序睡眠2s
    }
  • Goroutine 奉行通过通信来共享内存,而不是共享内存来通信

  • Channel
    • Channel是goroutine沟通的桥梁,大都是阻塞同步的
    • 通过make创建,close关闭(当程序简单时,回自动关闭)
    package main
    import (
        "fmt"
    )
    
    func main() {                 //主程序
        c := make(chan bool)      //初始化一个chan类型
        go func() {               //子程序
            fmt.Println("123...") //执行主程序
            c <- true             //通过<-存入bool类型到chan中
        }()
    fmt.Println(1)                //程序执行步骤:1st
    read_chan := <-c              //<-c 从chan中读取bool,程序执行步骤:2nd
    fmt.Println(read_chan)       //程序执行步骤:3rd
    }
    
    /*output
    1st     1           
    2nd     123...
    3rd     true
    */

    注意以上程序的执行顺序(channel无缓存时):先执行读取操作c<-c,因为channel中没有值,所以程序发生阻塞,此时执行chanel写操作,然后再执行读操作。

    • Channel是引用类型

    • 可以使用for range来迭代不断操作channel

    package main
    import (
        "fmt"
    )
    
    func main() {
        c := make(chan bool)      //初始化一个chan类型
        go func() {               //go结合匿名函数,构造并发
            fmt.Println("123...") //执行主程序
            c <- true             //通过<-存入bool类型到chan中
            close(c)              //关闭通道:必须明确在哪个地方关闭
        }()
    
        for v := range c {       //for循环chanel
        }
    }
    
    /*output
        123...
        true
    */
    • 可以设置单向(读&写)或双向通道--默认是双向通道

    • 可以设置缓存大小(默认为0,阻塞),在未被填充前不会发生阻塞(异步),比如缓存20个,可以同时进行20个读操作或者写操作,注意读的操作先于写的操作

    package main
    import (
        "fmt"
    )
    
    func main() { //主程序
        c := make(chan bool, 1)   //初始化一个chan类型,缓存为2
        go func() {               //子程序
            fmt.Println("123...") //执行主程序,执行步骤:2
            c <- true             //写操作,执行步骤:2
        }()
        fmt.Println(2)            //执行步骤:1
        fmt.Println(123, <-c)     //读操作,执行步骤:2
        fmt.Println(3)            //执行步骤:3
    }
    
    /*output
    1   2
    2   123...
    2   123 true
    3   3
        */

    设置缓存后,程序为异步,读,写操作同时完成,当读取channal中无数据时,也不会造成堵塞,因为与此同时,写操作也将发生。


有疑问加站长微信联系(非本文作者)

本文来自:博客园

感谢作者:failymao

查看原文:golang基础--Gocurrency并发

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

698 次点击  
加入收藏 微博
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传