Go中如何控制Goroutines的执行顺序？

Goroutine 执行顺序不可预测

在提供的代码片段中，两个 Goroutine 的执行顺序是不确定的。输出显示第二个 goroutine 首先执行，尽管它是在第一个 goroutine 之后启动的。这种行为是由于 Goroutine 的并发特性造成的，这意味着它们彼此独立执行。

Goroutine 中的同步机制

控制 Goroutine 执行的顺序，可以使用Go提供的同步机制，比如as:

Channels: 你可以使用通道来同步 goroutine 的执行。通道是允许 goroutine 发送和接收数据的通信通道。在下面的修改示例中，通道用于阻塞主 Goroutine，直到第一个 Goroutine 在第二个 Goroutine 启动之前完成执行。

func main() {

    c := make(chan int)

    go sum([]int{1, 2, 3}, c)

    // Use the channel to block until it receives a send
    x := <-c
    fmt.Println(x)

    // Then execute the next routine
    go sum([]int{4, 5, 6}, c)

    x = <-c
    fmt.Println(x)
}

等待组： 等待组是另一种同步机制，允许您等待多个 goroutine 完成执行后再继续。在下面的例子中，使用了一个等待组来确保所有的goroutine在主goroutine退出之前都完成。

func sum(a []int, c chan int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Println("summing: ", a)
    total := 0
    for _, v := range a {
        total += v
    }
    // Send total to c
    c <- total
}

func main() {

    c := make(chan int)
    wg := new(sync.WaitGroup)

    // Concurrently call the concurrent calls to sum, allowing execution to continue to the range of the channel
    go func() {
        // Increment the wait group, and pass it to the sum func to decrement it when it is complete
        wg.Add(1)
        go sum([]int{1, 2, 3}, c, wg)
        // Wait for the above call to sum to complete
        wg.Wait()
        // And repeat...
        wg.Add(1)
        go sum([]int{4, 5, 6}, c, wg)
        wg.Wait()
        // All calls are complete, close the channel to allow the program to exit cleanly
        close(c)
    }()

    // Range of the channel
    for theSum := range c {
        x := theSum
        fmt.Println(x)
    }

}

通过使用这些同步机制，你可以控制goroutine的执行顺序，并确保维持所需的操作顺序。

以上是Go中如何控制Goroutines的执行顺序？的详细内容。更多信息请关注PHP中文网其他相关文章！