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

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

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

1. 启动基本goroutine

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

package main
import (
"fmt"
"time"
)
func sayHello() {
fmt.Println("Hello from goroutine")
}
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
import (
"fmt"
"sync"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Worker %d starting\n", id)
// 模拟任务耗时
fmt.Printf("Worker %d done\n", id)
}
func main() {
var wg sync.WaitGroup
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之间安全传递数据的方式。

							

								
								

									FreeTTS
									
FreeTTS是一个免费开源的在线文本到语音生成解决方案，可以将文本转换成MP3，
								
								下载 
							
						
示例：通过channel接收结果
package main
import "fmt"
func fetchData(ch chan string) {
ch <- "data from goroutine"
}
func main() {
ch := make(chan string)
go fetchData(ch)
result := <-ch // 从channel读取数据
fmt.Println(result)
}
无缓冲channel会阻塞发送和接收，直到双方就绪；有缓冲channel可缓解短暂速度差异。
4. 使用select处理多个channel
当需要从多个channel中接收数据时，select 可以实现多路复用。
示例：
package main
import (
"fmt"
"time"
)
func sendMsg(ch chan string, msg string, delay time.Duration) {
time.Sleep(delay)
ch <- msg
}
func main() {
ch1 := make(chan string)
ch2 := make(chan string)
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
import (
"sync"
)
var counter int
var mu sync.Mutex
func increment(wg *sync.WaitGroup) {
defer wg.Done()
mu.Lock()
counter++
mu.Unlock()
}
基本上就这些。掌握这些基础方法，就能在Go中高效、安全地使用goroutine实现并发。关键是理解goroutine生命周期、同步机制和channel的使用场景。