golang 记录goroutine

发布时间:2024-10-02 19:59:09

1. 什么是goroutine

在Go语言中，我们可以使用goroutine来并发处理任务。一个goroutine就是一个轻量级的线程，由Go的运行时系统进行管理。

2. goroutine的优势

相比于传统的线程或进程，goroutine有以下几个优势：

轻量级：goroutine的栈空间只有几KB，相比于传统的线程节省了很多资源。
高效：goroutine的创建和销毁比线程更快，可以大量创建。
简单：使用go关键字就可以创建一个goroutine，非常方便。

3. 如何创建goroutine

要创建一个goroutine，只需要在函数调用前加上关键字go即可。例如：


go MyFunction()

这样就会创建一个新的goroutine并在其中执行MyFunction()函数。

4. goroutine如何通信

不同的goroutine之间可以通过共享内存的方式进行通信，但在Go语言中推荐使用channel来实现，并发安全的通信。通过channel可以在goroutine之间传递数据。

下面是一个简单的示例：


c := make(chan int)
go func() {
    c <- 42
}()
result := <-c
fmt.Println(result)

在上面的示例中，我们创建了一个int类型的channel，并启动了一个新的goroutine，它将数字42发送到了channel中。然后在主goroutine中，我们通过<-c接收到了这个值，并打印出来。

5. goroutine的调度

Go语言的运行时系统会自动进行goroutine的调度，确保所有的goroutine都可以被公平地执行。调度器会根据一定的策略，将任务分配给不同的处理器执行。

在使用多个goroutine时，我们无需手动控制任务的调度，可以专注于业务逻辑的编写。

6. 异常处理

在goroutine中，我们并不能像在主goroutine中那样直接使用try-catch块来捕获异常。但是我们可以使用defer关键字来处理可能发生的错误。示例如下：


func MyFunction() {
    defer func() {
        if err := recover(); err != nil {
            // 处理异常
            fmt.Println("发生错误:", err)
        }
    }()
    
    // 执行业务逻辑
    
    // 可能发生异常
    panic("发生了一个错误")
}

在上面的示例中，我们使用defer关键字定义了一个匿名函数，在函数执行完毕之前会被调用。如果发生了panic，就可以通过recover函数来捕获到并进行处理。

7. goroutine的数量控制

在某些场景下，我们需要控制同时执行的goroutine的数量，可以使用sync包中的WaitGroup类型来实现。示例如下：


var wg sync.WaitGroup

func MyFunction() {
    defer wg.Done()
    
    // 执行业务逻辑
}

func main() {
    wg.Add(5) // 设置要等待的goroutine数量
    
    for i := 0; i < 5; i++ {
        go MyFunction()
    }
    
    wg.Wait() // 等待所有的goroutine执行完成
}

在上面的示例中，我们使用WaitGroup来控制goroutine的数量。通过调用Add方法设置要等待的goroutine数量，然后在每个goroutine结束时调用Done方法。最后，调用Wait方法等待所有的goroutine执行完成。

8. 总结

通过使用goroutine，我们可以很方便地实现并发处理任务，并发编程变得更加简单高效。在开发中，我们可以充分利用goroutine的优势，提升程序的性能和响应速度。