在Golang中实现多协程并发执行非常简单，主要依赖于 goroutine 和 channel 配合同步机制。下面介绍几种常用方式，帮助你高效地启动多个协程并管理它们的执行。
1. 基础：使用 goroutine 启动并发任务
Goroutine 是轻量级线程，由 Go 运行时调度。通过 go 关键字即可启动一个协程。
package mainimport ("fmt""time")
func task(id int) {fmt.Printf("任务 %d 开始执行n", id)time.Sleep(1 * time.Second)fmt.Printf("任务 %d 执行完成n", id)}
func main() {for i := 1; i <= 3; i++ {go task(i)}
// 等待所有协程完成（临时方案）time.Sleep(2 * time.Second)}
注意：main 函数不会等待协程结束，所以需要阻塞主线程（如使用 Sleep），但这不推荐用于生产环境。
立即学习“go语言免费学习笔记（深入）”；
2. 推荐：使用 sync.WaitGroup 控制协程同步
WaitGroup 可以等待一组协程完成，是控制并发的常用方式。
package mainimport ("fmt""sync""time")
func worker(id int, wg *sync.WaitGroup) {defer wg.Done() // 任务完成，计数器减一fmt.Printf("协程 %d 开始工作n", id)time.Sleep(time.Second)fmt.Printf("协程 %d 完成n", id)}
func main() {var wg sync.WaitGroup
for i := 1; i <= 5; i++ { wg.Add(1) // 计数器加一 go worker(i, &wg)}wg.Wait() // 阻塞，直到所有协程调用 Done()fmt.Println("所有协程执行完毕")}
3. 使用 channel 进行协程间通信与结果收集
如果需要获取协程的执行结果，可以使用 channel 来传递数据。
php中级教程之ajax技术
AJAX即“Asynchronous Javascript And XML”（异步JavaScript和XML），是指一种创建交互式网页应用的网页开发技术。它不是新的编程语言，而是一种使用现有标准的新方法，最大的优点是在不重新加载整个页面的情况下，可以与服务器交换数据并更新部分网页内容，不需要任何浏览器插件，但需要用户允许JavaScript在浏览器上执行。《php中级教程之ajax技术》带你快速
2114 查看详情
package mainimport ("fmt""sync")
func fetchData(id int, ch chan string) {// 模拟耗时操作result := fmt.Sprintf("数据 %d 获取完成", id)ch <- result}
func main() {resultCh := make(chan string, 5) // 缓冲 channelvar wg sync.WaitGroup
for i := 1; i <= 5; i++ { wg.Add(1) go func(i int) { defer wg.Done() fetchData(i, resultCh) }(i)}// 协程结束后关闭 channelgo func() { wg.Wait() close(resultCh)}()// 从 channel 中读取结果for result := range resultCh { fmt.Println(result)}}
4. 控制并发数量：使用带缓冲的 channel 实现协程池
当协程数量过多时，可以通过信号量模式限制并发数。
package mainimport ("fmt""sync""time")
func workerWithLimit(id int, sem chan struct{}, wg *sync.WaitGroup) {defer wg.Done()
sem <- struct{}{} // 获取信号量fmt.Printf("协程 %d 开始执行n", id)time.Sleep(500 * time.Millisecond)fmt.Printf("协程 %d 执行结束n", id)<-sem // 释放信号量}
func main() {const maxConcurrency = 3sem := make(chan struct{}, maxConcurrency) // 最多允许 3 个并发var wg sync.WaitGroup
for i := 1; i <= 10; i++ { wg.Add(1) go workerWithLimit(i, sem, &wg)}wg.Wait()fmt.Println("所有任务完成")}
这种方式能有效避免资源耗尽，适用于大量任务但需限制同时运行数量的场景。
基本上就这些。掌握 goroutine、WaitGroup、channel 和并发控制技巧，就能灵活实现各种并发需求。关键是避免竞态条件，合理同步和传递数据。不复杂但容易忽略细节。
以上就是如何使用Golang实现多协程并发执行的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1137842.html
微信扫一扫 
支付宝扫一扫 
