您现在的位置是：网站首页> 编程资料编程资料

golang基础之Gocurrency并发_Golang_

2023-05-26 465人已围观

简介 golang基础之Gocurrency并发_Golang_

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中无数据时，也不会造成堵塞，因为与此同时，写操作也将发生。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

您可能感兴趣的文章:

上一篇：golang struct 实现 interface的方法_Golang_

下一篇：golang基础之Interface接口的使用_Golang_

相关内容

点击排行

本栏推荐

猜你喜欢

-六神源码网