首页 >后端开发 >Golang >如何控制Go例程的执行顺序?

如何控制Go例程的执行顺序?

Mary-Kate Olsen
Mary-Kate Olsen原创
2024-12-13 21:59:31251浏览

How Can I Control the Execution Order of Go Routines?

Go 例程执行顺序

此代码展示了 Go 例程执行顺序的概念,其中两个并发的“go”例程或 goroutine ,同时执行,但没有任何保证的顺序。

代码定义了一个 sum 函数,它接受一个整数数组和一个通道作为输入。该函数计算数组中整数的总和,并将结果发送到提供的通道。

在 main 函数中,创建了一个通道 c 以便于 goroutine 之间的通信。启动两个 goroutine,每个 goroutine 使用不同的输入数组执行 sum 函数,并将结果发送到 c。

程序然后从通道 c 接收 goroutine 发送的值并打印它们。然而,goroutines 完成的顺序是不确定的,因此输出顺序可能会有所不同。

要控制 goroutine 的执行顺序,您可以使用各种机制,例如阻塞通道或标准提供的同步原语图书馆。以下是一些示例:

1。阻塞通道:

在此修改版本中,goroutines 通过阻塞主例程来顺序执行,直到从通道接收到一个值:

func main() {
    c := make(chan int)

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

    // Block until a value is received from c
    x := <-c
    fmt.Println(x)

    go sum([]int{4, 5, 6}, c)

    // Block until a value is received from c
    x = <-c
    fmt.Println(x)
}

2。带通道的等待组:

另一种选择是在通道上使用等待组和范围,以确保所有 goroutine 在处理结果之前已完成执行:

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

    wg.Add(1)
    go sum([]int{1, 2, 3}, c, wg)
    wg.Wait()

    wg.Add(1)
    go sum([]int{4, 5, 6}, c, wg)
    wg.Wait()

    close(c)

    for x := range c {
        fmt.Println(x)
    }
}

这些技术允许您控制 goroutine 的执行顺序,以在并发程序中实现所需的行为。

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

声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn