如何在Golang中实现goroutine并发执行-Golang-PHP中文网

如何在Golang中实现goroutine并发执行

P粉602998670

发布： 2025-10-19 10:14:01

原创

401人浏览过

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

如何在golang中实现goroutine并发执行

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

启动基本的goroutine

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

示例：

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

登录后复制

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

使用channel进行goroutine通信

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

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

php中级教程之ajax技术

AJAX即“Asynchronous Javascript And XML”（异步JavaScript和XML），是指一种创建交互式网页应用的网页开发技术。它不是新的编程语言，而是一种使用现有标准的新方法，最大的优点是在不重新加载整个页面的情况下，可以与服务器交换数据并更新部分网页内容，不需要任何浏览器插件，但需要用户允许JavaScript在浏览器上执行。《php中级教程之ajax技术》带你快速

2114

查看详情

示例：带缓冲的channel控制并发

package main
<p>import "fmt"</p><p>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
}
}</p><p>func main() {
jobs := make(chan int, 5)
results := make(chan int, 5)</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">// 启动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
<p>import (
"fmt"
"sync"
)</p><p>func task(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Task %d is 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 <= 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并发执行的详细内容，更多请关注php中文网其它相关文章！