如何在Golang中实现基础的goroutine并发执行_Golang goroutine并发执行方法汇总-Golang-PHP中文网

如何在Golang中实现基础的goroutine并发执行_Golang goroutine并发执行方法汇总

P粉602998670

发布： 2025-11-19 08:25:17

原创

514人浏览过

Goroutine是Go并发核心，通过go关键字启动轻量级线程，配合WaitGroup同步、channel通信、select多路复用及Mutex保护共享资源，实现高效安全并发。

如何在golang中实现基础的goroutine并发执行_golang goroutine并发执行方法汇总

在Golang中，goroutine 是实现并发的核心机制。它是一种轻量级线程，由Go运行时管理，启动成本低，适合高并发场景。下面介绍几种基础且实用的goroutine并发执行方法。

1. 启动基本goroutine

使用 go 关键字即可启动一个goroutine，函数会异步执行。

示例：

package main
<p>import (
"fmt"
"time"
)</p><p>func sayHello() {
fmt.Println("Hello from goroutine")
}</p><p>func main() {
go sayHello()
time.Sleep(100 * time.Millisecond) // 等待goroutine执行
fmt.Println("Main function")
}

登录后复制

注意：主函数退出后，所有goroutine都会终止，因此需要适当同步（如Sleep或WaitGroup）来确保执行完成。

2. 使用sync.WaitGroup等待多个goroutine

当需要等待一组goroutine完成时，sync.WaitGroup 是最常用的同步工具。

立即学习“go语言免费学习笔记（深入）”；

示例：

package main
<p>import (
"fmt"
"sync"
)</p><p>func worker(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Worker %d starting\n", id)
// 模拟任务耗时
fmt.Printf("Worker %d done\n", id)
}</p><p>func main() {
var wg sync.WaitGroup</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">for i := 1; i <= 3; i++ {
    wg.Add(1)
    go worker(i, &wg)
}

wg.Wait() // 阻塞直到所有worker调用Done()
fmt.Println("All workers finished")

登录后复制

}

3. 使用channel进行goroutine通信

Go提倡“通过通信共享内存”，channel 是goroutine之间安全传递数据的方式。

码哩写作

最懂作者的AI辅助创作工具

查看详情

示例：通过channel接收结果

package main
<p>import "fmt"</p><p>func fetchData(ch chan string) {
ch <- "data from goroutine"
}</p><p>func main() {
ch := make(chan string)
go fetchData(ch)
result := <-ch // 从channel读取数据
fmt.Println(result)
}

登录后复制

无缓冲channel会阻塞发送和接收，直到双方就绪；有缓冲channel可缓解短暂速度差异。

4. 使用select处理多个channel

当需要从多个channel中接收数据时，select 可以实现多路复用。

示例：

package main
<p>import (
"fmt"
"time"
)</p><p>func sendMsg(ch chan string, msg string, delay time.Duration) {
time.Sleep(delay)
ch <- msg
}</p><p>func main() {
ch1 := make(chan string)
ch2 := make(chan string)</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">go sendMsg(ch1, "msg from 1", 100*time.Millisecond)
go sendMsg(ch2, "msg from 2", 200*time.Millisecond)

for i := 0; i < 2; i++ {
    select {
    case msg := <-ch1:
        fmt.Println(msg)
    case msg := <-ch2:
        fmt.Println(msg)
    }
}

登录后复制

}

5. 避免常见并发问题

goroutine虽简单，但共享变量可能引发竞态条件。建议：

避免多个goroutine直接读写同一变量
使用channel传递数据而非共享内存
必要时使用 sync.Mutex 保护临界区

示例：使用Mutex保护计数器

package main
<p>import (
"sync"
)</p><p>var counter int
var mu sync.Mutex</p><p>func increment(wg *sync.WaitGroup) {
defer wg.Done()
mu.Lock()
counter++
mu.Unlock()
}

登录后复制

基本上就这些。掌握这些基础方法，就能在Go中高效、安全地使用goroutine实现并发。关键是理解goroutine生命周期、同步机制和channel的使用场景。

以上就是如何在Golang中实现基础的goroutine并发执行_Golang goroutine并发执行方法汇总的详细内容，更多请关注php中文网其它相关文章！