沙龙国际沙龙会官方网址沙龙国际沙龙会官方网址

沙龙会S36官方线路
沙龙国际管理

golang基础--Gocurrency并发

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 奉行通过通信来共享内存,而不是共享内存来通信

ChannelChannel是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<-c) //读操作,执行步骤:2 fmt.Println(3) //执行步骤:3}/*output1 22 123...2 123 true3 3 */

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

, 1, 0, 9);

欢迎阅读本文章: 陈生荣

sa36亚洲国际代理

沙龙会S36官方线路