欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

golang基础--Gocurrency并发

程序员文章站 2022-06-24 08:40:55
goroutine只是由官方实现的超级"线程池"而已,每个实例4 5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。 并发不是并行(多CPU): 并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。 通过go关键字实 ......
  • 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中无数据时,也不会造成堵塞,因为与此同时,写操作也将发生。