深入理解Go语言中time.Sleep在并发Goroutine中的行为

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语言免费学习笔记（深入）”；

行为解析：

Shell脚本编写基础 中文WORD版

Shell本身是一个用C语言编写的程序，它是用户使用Linux的桥梁。Shell既是一种命令语言，又是一种程序设计语言。作为命令语言，它交互式地解释和执行用户输入的命令；作为程序设计语言，它定义了各种变量和参数，并提供了许多在高级语言中才具有的控制结构，包括循环和分支。它虽然不是Linux系统核心的一部分，但它调用了系统核心的大部分功能来执行程序、建立文件并以并行的方式协调各个程序的运行。因此，对于用户来说，shell是最重要的实用程序，深入了解和熟练掌握shell的特性极其使用方法，是用好Linux系统

24

查看详情

1. Goroutine 0 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停
2. Goroutine 1 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停
3. Goroutine 2 启动 -> 执行到time.Sleep(4 * time.Second) -> 暂停 ...
4. 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完成其内部逻辑（包括睡眠）后，提供一个同步点来收集这些并发任务的输出。

注意事项与总结

1. time.Sleep的局部性： 始终记住time.Sleep只暂停调用它的Goroutine。这是理解Go并发行为的基础。
2. 并发与并行： 在多核处理器上，这些Goroutine的time.Sleep会并行执行。即使在单核处理器上，Go运行时也会通过时间片轮转（preemptive scheduling）的方式，让多个Goroutine看起来是并发执行的。
3. 精确计时与同步： 如果需要实现Goroutine的顺序暂停、协调它们的启动/停止，或者在特定时间点同步多个Goroutine，则不应仅仅依赖time.Sleep。更合适的做法是使用Go提供的同步原语，例如：
   • sync.WaitGroup： 用于等待一组Goroutine完成。
   • 通道（Channels）： 用于Goroutine之间的通信和协调，可以实现更复杂的同步模式。
   • context包： 用于取消Goroutine或设置超时。
4. 避免过度使用time.Sleep： 在实际生产代码中，应尽量避免使用time.Sleep作为Goroutine间同步或等待事件发生的机制，因为它不够精确且可能导致性能问题。通常，通道和sync.WaitGroup是更优的选择。

通过本文的解析，我们了解到time.Sleep在Go语言并发环境中是并行暂停的，每个Goroutine都独立地进入睡眠状态并几乎同时醒来。理解这一核心机制对于编写高效、正确的Go并发程序至关重要。

以上就是深入理解Go语言中time.Sleep在并发Goroutine中的行为的详细内容，更多请关注php中文网其它相关文章！