当前位置：首页 > 文章列表 > Golang > Go教程 > goroutine对golang函数的执行流程有什么影响？

goroutine对golang函数的执行流程有什么影响？

2024-05-04 13:02:34 0浏览收藏

推广推荐

支持 PC / 移动端，安全直达

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《goroutine对golang函数的执行流程有什么影响？》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

Go 中的 goroutine 实现并发，可让函数并发执行，通过通道实现通信，并提供对并发的控制。goroutine 的使用可提升程序性能，尤其适用于处理阻塞任务。示例代码展示了 goroutine 的并行执行、通道通信和并发控制。

goroutine对golang函数的执行流程有什么影响？

Go 程对 Go 函数执行流程的影响

在 Go 语言中，goroutine 是并发执行代码块的轻量级线程。与传统线程不同，goroutine 是一种协程，这意味着它们不会占据自己的内核线程，而是与其他 goroutine 共享同一线程池。这种特性让 Goroutine 变得轻量、高效，非常适合处理并发任务。

Go 函数的执行流程受到 goroutine 的影响表现在以下方面：

1. 并行执行

goroutine 允许函数并发执行。通过创建 goroutine，您可以让多个函数同时运行，而无需等待其他函数完成。这大大提高了程序的性能，尤其是在处理 I/O 操作等阻塞任务时。

示例代码：

package main

import (
    "fmt"
    "time"
)

func main() {
    go func() {
        time.Sleep(1 * time.Second)
        fmt.Println("Goroutine says hello!")
    }()

    fmt.Println("Main function says hi!")
}

输出：

Main function says hi!
Goroutine says hello!

这段代码中，我们创建了一个 goroutine，在 goroutine 中打印“Goroutine says hello!”。与此同时，main 函数打印“Main function says hi!”。由于 goroutine 是并发执行的，因此这两条消息将同时打印。

2. 通道通信

goroutine 之间的通信通过通道实现。通道是一种类型安全的通信机制，它允许 goroutine 发送和接收值。这使您可以协调 goroutine 之间的任务，并控制数据流。

示例代码：

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    var wg sync.WaitGroup
    ch := make(chan int)

    go func() {
        for i := 0; i < 10; i++ {
            ch <- i
        }
        wg.Done()
    }()

    go func() {
        for i := 0; i < 10; i++ {
            fmt.Println(<-ch)
        }
        wg.Done()
    }()

    wg.Add(2)
    wg.Wait()
}

输出：

这段代码创建了两个 goroutine。第一个 goroutine 将整数从 0 到 9 发送到通道，第二个 goroutine 从通道接收整数并打印。waitGroup 用于确保两个 goroutine 都完成，然后再退出主函数。

3. 控制并发

goroutine 增加了对并发性的控制。您可以创建任意数量的 goroutine，但重要的是要管理好它们，以避免资源过度消耗。Go 语言内置了一些特性来帮助您控制并发，例如 context 和 sync 包。

示例代码：

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()

    var mu sync.Mutex
    total := 0

    for i := 0; i < 10000; i++ {
        go func(i int) {
            mu.Lock()
            defer mu.Unlock()

            total += i
        }(i)
    }

    <-ctx.Done()
    fmt.Println("Total:", total)
}

输出：