golang基础--Gocurrency并发

golang基础--Gocurrency并发,第1张

概述goroutine只是由官方实现的超级"线程池"而已,每个实例4-5kb的栈内存占用和用于实现机制而大幅减少的创建和销毁开销。 并发不是并行(多CPU): Concurrency Is Not Parallelism 并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。 通过go关键字实现多线程 package maini

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

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

并发主要由切换时间片来实现"同时"运行,并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力。 通过go关键字实现多线程
package mainimport (    "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 mainimport (    "fmt")func main() {                 //主程序    c := make(chan bool)      //初始化一个chan类型    go func() {               //子程序        fmt.Println("123...") //执行主程序        c <- true             //通过<-存入bool类型到chan中    }()fmt.Println(1)                //程序执行步骤:1stread_chan := <-c              //<-c 从chan中读取bool,程序执行步骤:2ndfmt.Println(read_chan)       //程序执行步骤:3rd}/*output1st     1           2nd     123...3rd     true*/

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

Channel是引用类型

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

package mainimport (    "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 mainimport (    "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}/*output1   22   123...2   123 true3   3    */

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

总结

以上是内存溢出为你收集整理的golang基础--Gocurrency并发全部内容,希望文章能够帮你解决golang基础--Gocurrency并发所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/langs/1270413.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2022-06-08
下一篇2022-06-08

发表评论

登录后才能评论

评论列表(0条)

    保存