Golang如何实现goroutine并发执行

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《Golang如何实现goroutine并发执行》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

Golang通过go关键字启动goroutine实现并发，配合channel进行通信，使用WaitGroup等待执行完成，避免竞态与泄漏。

在Golang中实现goroutine并发执行非常直接，Go语言通过轻量级线程（goroutine）和通道（channel）提供了强大的并发支持。你只需要在函数调用前加上 go 关键字，就能启动一个新goroutine并发运行。

启动基本的goroutine

每个goroutine是一个独立执行的函数，由Go运行时调度管理。它比操作系统线程更轻量，可以轻松创建成千上万个。

package main
import (
"fmt"
"time"
)
func sayHello() {
fmt.Println("Hello from goroutine")
}
func main() {
go sayHello() // 启动一个goroutine
time.Sleep(100 * time.Millisecond) // 等待goroutine执行完成
fmt.Println("Main function ends")
}

如果不加 time.Sleep，主程序可能在goroutine执行前就退出了，导致看不到输出。

使用channel进行goroutine通信

多个goroutine之间不能直接共享内存通信，推荐使用channel传递数据，避免竞态条件。

package main
import "fmt"
func worker(id int, jobs <-chan int, results chan<- int) {
for job := range jobs {
fmt.Printf("Worker %d processing job %d\n", id, job)
results <- job * 2
}
}
func main() {
jobs := make(chan int, 5)
results := make(chan int, 5)
// 启动3个worker goroutine
for w := 1; w <= 3; w++ {
    go worker(w, jobs, results)
}

// 发送5个任务
for j := 1; j <= 5; j++ {
    jobs <- j
}
close(jobs)

// 收集结果
for a := 1; a <= 5; a++ {
    <-results
}
}

使用sync.WaitGroup等待所有goroutine完成

当不需要返回值时，可以用 sync.WaitGroup 来等待一组goroutine执行完毕。

package main
import (
"fmt"
"sync"
)
func task(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Task %d is done\n", id)
}
func main() {
var wg sync.WaitGroup
for i := 1; i <= 5; i++ {
    wg.Add(1)
    go task(i, &wg)
}

wg.Wait() // 阻塞直到所有task调用Done()
fmt.Println("All tasks completed")
}

基本上就这些。合理使用go关键字、channel和WaitGroup，就能高效安全地实现并发。注意避免常见问题如goroutine泄漏、死锁和竞态条件。配合context包还能实现超时控制和取消机制。不复杂但容易忽略细节。

到这里，我们也就讲完了《Golang如何实现goroutine并发执行》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！