golang gorouting

2024-11-27 20:30:33 编程来源：ZONE.CI 全球网 0 阅读模式

goroutine是Go语言中的一个重要特性，它可以让我们更高效地实现并发。通过goroutine，我们可以并发地执行多个函数或方法，而不需要显式地使用线程和锁来实现同步。在本文中，我将详细介绍goroutine的使用方法以及其相关的一些注意事项。

什么是goroutine

在Go语言中，goroutine是一个轻量级的线程，它由Go运行时系统管理，可以在一台机器上同时运行成千上万个goroutine，而不会导致系统资源过度消耗。与传统的线程相比，goroutine拥有更低的创建和销毁成本，以及更小的内存开销。

如何创建goroutine

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

go func() {
    // 并发执行的代码
}()

在上面的例子中，我们通过go关键字创建了一个匿名函数的goroutine。这个匿名函数会在一个新的goroutine中并发地执行，而不会阻塞当前的goroutine。

除了匿名函数外，我们还可以使用具名函数来创建goroutine：

func myFunc() {
    // 并发执行的代码
}

go myFunc()

在上面的例子中，我们定义了一个名为myFunc的函数，并通过go关键字将其放入一个新的goroutine中并发执行。

如何等待goroutine结束

在某些情况下，我们可能需要等待一个goroutine执行完毕后再继续执行后续的代码。Go语言提供了sync包中的WaitGroup类型来实现这个功能。具体做法是：

创建一个WaitGroup实例
在每个goroutine开始执行之前，调用WaitGroup的Add方法将计数加1
在每个goroutine执行结束时，调用WaitGroup的Done方法将计数减1
在主goroutine中，调用WaitGroup的Wait方法等待所有goroutine执行完毕

下面是一个使用WaitGroup等待goroutine结束的示例：

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    wg.Add(2) // 设置计数器为2

    go func() {
        defer wg.Done() // goroutine结束时将计数器减1
        fmt.Println("First goroutine")
    }()

    go func() {
        defer wg.Done() // goroutine结束时将计数器减1
        fmt.Println("Second goroutine")
    }()

    wg.Wait() // 等待所有goroutine执行完毕
    fmt.Println("All goroutines finished")
}

在上面的例子中，我们创建了两个goroutine，并使用WaitGroup将计数器设置为2。当每个goroutine执行完毕时，通过调用Done方法将计数器减1。最后，在主goroutine中调用Wait方法来等待所有goroutine执行完毕。