
Go语言并发基础:Goroutine与go关键字
go语言通过goroutine实现了轻量级的并发。goroutine可以看作是用户态的线程,由go运行时(runtime)进行调度,相比操作系统线程,其创建和销毁开销极小。通过在函数调用前加上go关键字,我们就可以启动一个新的goroutine来并发执行该函数,而主goroutine(或调用者goroutine)将继续执行后续代码。
例如,以下代码片段展示了如何并发地启动多个getHostName函数:
package main
import (
"fmt"
"strconv"
"time"
)
func getHostName(h chan string, ipAdresse string, n int) {
// 在此处暂停当前Goroutine
time.Sleep(4 * time.Second)
ip := ipAdresse + strconv.Itoa(n)
// 模拟一些网络操作或条件判断
if n%2 == 0 { // 假设偶数索引成功,奇数索引失败
h <- ip + " - Success"
} else {
h <- "error" + strconv.Itoa(n)
}
}
func main() {
max := 5
haveHost := make(chan string, max) // 带缓冲的通道
ipAdresse_3 := "192.168.1."
fmt.Println("启动Goroutine...")
for i := 0; i < max; i++ {
go getHostName(haveHost, ipAdresse_3, i)
}
fmt.Println("所有Goroutine已启动,等待结果...")
for i := 0; i < max; i++ {
result := <-haveHost
fmt.Println(result)
}
fmt.Println("所有结果已接收。")
}在上述main函数中,一个for循环启动了max个getHostName Goroutine。一旦go getHostName(...)被调用,一个新的Goroutine就会被创建并开始执行getHostName函数体,而main Goroutine会立即继续循环,启动下一个Goroutine,而不会等待前一个Goroutine完成。
time.Sleep的局部性与并发行为
time.Sleep(d Duration)函数的作用是使当前正在执行的Goroutine暂停指定的时长d。这是一个非常关键的细节:time.Sleep只会影响调用它的那个Goroutine,而不会阻塞整个程序或其他的Goroutine。
结合上述示例,当max个getHostName Goroutine被并发启动后,它们几乎同时开始执行。每个Goroutine都会独立地执行到time.Sleep(4 * time.Second)这一行。此时,每个Goroutine都会暂停自身4秒钟。由于这些Goroutine是并发执行的,它们的暂停是同时发生的。
立即学习“go语言免费学习笔记(深入)”;
行为解析:
系统简介1:安全可靠: 在微软主推的.NET开发平台上,采用业界领先的ASP.NET技术和C#语言开发,不仅安全可靠,并能保证系统的高性能运行。2:简单易用:版纳武林DIY企业建站系统真正做到以人为本、以用户体验为中心,能使您快速搭建您的网站。后台管理操作简单,一目了然,没有夹杂多余的功能和广告。3:布局易改:版纳武林DIY企业建站系统采用的是博客形式的风格管理,让您真正感受到我的地盘听我的.4:
- Goroutine 0 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停
- Goroutine 1 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停
- Goroutine 2 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停 ...
- Goroutine max-1 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停
所有这些暂停几乎在同一时间点开始,并且都会持续4秒。因此,在4秒钟之后,所有的Goroutine将几乎同时从睡眠中醒来,继续执行后续的代码(例如构建IP地址、发送结果到通道)。这就是为什么会观察到所有Goroutine几乎同时完成,而不是一个接一个地暂停和完成。
常见误区澄清
用户最初的疑问“Why does sleep pause only once?”(为什么看起来只有一次暂停?)源于一个常见的误解:认为time.Sleep会像一个全局锁一样,阻塞整个程序或所有并发任务。然而,Go语言的并发模型中,time.Sleep是Goroutine局部的,它仅作用于调用它的特定执行流。
通道(c chan string)在示例中用于Goroutine之间传递结果,它负责收集各个Goroutine完成任务后发送的数据。通道本身并不直接控制time.Sleep的并发行为,而是在Goroutine完成其内部逻辑(包括睡眠)后,提供一个同步点来收集这些并发任务的输出。
注意事项与总结
- time.Sleep的局部性: 始终记住time.Sleep只暂停调用它的Goroutine。这是理解Go并发行为的基础。
- 并发与并行: 在多核处理器上,这些Goroutine的time.Sleep会并行执行。即使在单核处理器上,Go运行时也会通过时间片轮转(preemptive scheduling)的方式,让多个Goroutine看起来是并发执行的。
-
精确计时与同步: 如果需要实现Goroutine的顺序暂停、协调它们的启动/停止,或者在特定时间点同步多个Goroutine,则不应仅仅依赖time.Sleep。更合适的做法是使用Go提供的同步原语,例如:
- sync.WaitGroup: 用于等待一组Goroutine完成。
- 通道(Channels): 用于Goroutine之间的通信和协调,可以实现更复杂的同步模式。
- context包: 用于取消Goroutine或设置超时。
- 避免过度使用time.Sleep: 在实际生产代码中,应尽量避免使用time.Sleep作为Goroutine间同步或等待事件发生的机制,因为它不够精确且可能导致性能问题。通常,通道和sync.WaitGroup是更优的选择。
通过本文的解析,我们了解到time.Sleep在Go语言并发环境中是并行暂停的,每个Goroutine都独立地进入睡眠状态并几乎同时醒来。理解这一核心机制对于编写高效、正确的Go并发程序至关重要。









