当前位置: 代码迷 >> 综合 >> golang 协程(goroutine)
  详细解决方案

golang 协程(goroutine)

热度:17   发布时间:2024-03-06 00:24:01.0

A goroutine is a lightweight thread managed by the Go runtime.

Goroutine可以认为是一个轻量级的线程, 创建一个Goroutine其较线程开销很小, 因此通常情况下可以并发运行数千个协程

协程对比线程的优势

  • 与线程相比,goroutine非常cheap。它们的堆栈大小只有几kb,并且堆栈可以根据应用程序的需要进行扩展和收缩,而对于线程,则必须指定并固定堆栈大小
  • Goroutines被多路复用到更少的操作系统线程。在具有数千个Goroutine的程序中,可能只有一个线程。如果该线程块中的任何Goroutine说正在等待用户输入,则将创建另一个操作系统线程,并将其余的Goroutines移至新的OS线程。所有这些都由运行时小心处理,作为程序员,我们从这些复杂的细节中抽象出来,并获得了一个干净的API来处理并发
  • Goroutine使用channel进行通信。通过设计channel可以防止在使用Goroutines访问共享内存时发生争用情况。可以将channel视为使用Goroutine进行通信的管道

启动Goroutine

go hello()
  • 当启动新的Goroutine时,goroutine调用会立即返回。与函数不同,控件不等待Goroutine完成执行。在Goroutine调用之后,控件会立即返回到下一行代码,并且Goroutine中的所有返回值都将被忽略。
  • Main Goroutine应该正在运行,其他Goroutine才能运行。如果Main Goroutine终止,则该程序将终止,并且不会运行其他Goroutine。

并发模型

1. channel
2. sync包中的WaitGroup,主要有三个方法:- Add, 可以添加或减少 goroutine的数量.- Done, 相当于Add(-1).- Wait, 执行后会堵塞主线程,直到WaitGroup 里的值减至0.WaitGroup 第一次使用后,不能被拷贝---func main(){var wg sync.WaitGroupvar urls = []string{"http://www.golang.org/","http://www.google.com/",}for _, url := range urls {wg.Add(1)go func(url string) {defer wg.Done()http.Get(url)}(url)}wg.Wait()}
3. 在Go 1.7 以后引进的强大的Context上下文,实现并发控制