189 8069 5689

go中的Golang协程怎么分析

这篇文章跟大家分析一下“go中的Golang协程怎么分析”。内容详细易懂,对“go中的Golang协程怎么分析”感兴趣的朋友可以跟着小编的思路慢慢深入来阅读一下,希望阅读后能够对大家有所帮助。下面跟着小编一起深入学习“go中的Golang协程怎么分析”的知识吧。

成都做网站、成都网站制作介绍好的网站是理念、设计和技术的结合。创新互联建站拥有的网站设计理念、多方位的设计风格、经验丰富的设计团队。提供PC端+手机端网站建设,用营销思维进行网站设计、采用先进技术开源代码、注重用户体验与SEO基础,将技术与创意整合到网站之中,以契合客户的方式做到创意性的视觉化效果。

1. Hello Goroutine

    

package main
import (
   "fmt"
)

func main() {

go sayHello()

}

func sayHello() {
  fmt.Println("Hello Goroutine !!!")
}

    

    go语言开启协程的关键词是go,后面接着一个匿名函数或者一个自定义的函数,但是,如果运行了上面的代码,你会发现终端并没有输出‘Hello Gorounitn !!!’,为什么呢?

    上面的代码并没有问题,不会执行错误,之所以不会输出是因为在golang语言中,main函数也是一个协程,而且是主协程。什么意思呢?就是每当你执行go项目时(必需有main函数,而且只能有一个main函数),会首先开启一个main函数的主协程,这个主协程的执行时间会影响到子协程,子协程就是go关键词加函数,如果主协程先执行完毕,那么子协程就不会被执行,所以 我把代码改成这样:

package main
import (
  "fmt"
  "time"
)

func main() {
  go sayHello()
  time.Sleep(time.Second)
}

func sayHello() {
  fmt.Println("Hello Goroutine !!!")
}

输出:

Hello Goroutine !!!

sleep 1s,等待子协程执行,所以会有输出。

2. WaitGroup

    等待子协程执行用睡眠的方式不符合实际开发,所以sync包下的WaitGroup可以解决这个问题,代码:

package main
import (
  "fmt"
  "sync"
)

func main() {
  wg := &sync.WaitGroup{}
  wg.Add(2)
  go sayHello(wg)
  go sayHello2(wg)
  wg.Wait()
}

func sayHello(wg *sync.WaitGroup) {
  defer wg.Done()
  fmt.Println("Hello Goroutine !!!")
}

func sayHello2(wg *sync.WaitGroup) {
  defer wg.Done()
  fmt.Println("Hello Golang !!!")
}

解释:在main函数里声明一个wg变量,wg.Add(2)的意思是我这里有两个协程要执行,所以传入2,如果你有n个协程呢?那就传入n,wg.Done()相当与wg.Add(-1)就是该子协程执行完毕。wg.Wait()就是告诉主协程要等待子协程执行完毕才能退出。

3. Channel

    channel,又叫管道,在go里面的管道是协程之间通信的渠道,类似于咱们常用的消息队列。

package main
import (
  "fmt"
  "strconv"
)

func main() {
  ch := make(chan string)

  for i := 0; i <= 10; i++ {

     go demo(ch, "Hello Channel"+strconv.Itoa(i))
  }

  for d := range ch {
     fmt.Println(">>>>>>>>>>>>>>", d)
  }
}

func demo(c chan string, data string) {
  c <- data
}

    简单说明一下,这里就是实例化了一个string类型的管道,在调用函数的时候会把管道当作参数传递过去,然后在调用函数里面我们不输出结果,然后把结果通过管道返还回去,然后再主线程里面我们通过for range循环依次取出结果!

    但是这个程序是有bug的,在程序的运行的最后会出现一个fatal error,提示所有的协程都进入睡眠状态,死锁!

       go的管道默认是阻塞的(假如你不设置缓存的话),你那边放一个,我这头才能取一个,如果你那边放了东西这边没人取,程序就会一直等下去,死锁了,同时,如果那边没人放东西,你这边取也取不到,也会发生死锁!

    如何解决这个问题呢?标准的做法是主动关闭管道,或者你知道你应该什么时候关闭管道, 当然你结束程序管道自然也会关掉!针对上面的演示代码,可以这样写:

var (
  i int
)
for d := range ch {
  fmt.Println(">>>>>>>>>>>>>>", d)
  //
  if i >= 10 {
     close(ch)
  }
  i++
}

因为我们明确知道总共会输出11个结果,所以这里简单做了一个判断,大于等于10就关闭管道退出for循环,就不会报错了!虽然不是符合实际开发代码规范,但是可以使用,能够解释原理。

go是什么

golang是一种编译语言,可以将代码编译为机器代码,编译后的二进制文件可以直接部署到目标机器而无需额外的依赖,所以golang的性能优于其他的解释性语言,且可以在golang中使用goroutine来实现并发性,它提供了一个非常优雅的goroutine调度程序系统,可以很容易地生成数百万个goroutine。

关于go中的Golang协程怎么分析就分享到这里啦,希望上述内容能够让大家有所提升。如果想要学习更多知识,请大家多多留意小编的更新。谢谢大家关注一下创新互联网站!


名称栏目:go中的Golang协程怎么分析
URL链接:http://cdxtjz.com/article/pgccse.html

其他资讯