当前位置：首页 > article >正文

【Golang 面试题】每日 3 题（五十四）

article 2025/2/26 18:44:23

✍个人博客：Pandaconda-CSDN博客
📣专栏地址：http://t.csdnimg.cn/UWz06
📚专栏简介：在这个专栏中，我将会分享 Golang 面试中常见的面试题给大家~
❤️如果有收获的话，欢迎点赞👍收藏📁，您的支持就是我创作的最大动力💪

160. MP 中 work stealing 机制

GMP 中的 work stealing 机制是指在某个 M 线程的本地队列中没有 Goroutine 可供执行时，它会从其他 M 线程的本地队列中偷取 Goroutine 来执行。

具体地，work stealing 机制的实现过程如下：

每个 M 线程都有一个本地队列，用于存储待执行的 Goroutine。当一个 Goroutine 被创建时，它会被加入到一个本地队列中等待调度。
当一个 M 线程的本地队列中没有 Goroutine 可供执行时，它会从其他 M 线程的本地队列中随机选择一个队列，并尝试从该队列中偷取一些 Goroutine 来执行。在此期间，当前 M 线程会不断尝试从全局队列中获取 Goroutine 并将其调度到本地队列中执行。
当一个 M 线程偷取了其他 M 线程的 Goroutine 后，它会将这些 Goroutine 添加到自己的本地队列中，并将它们调度到绑定的 P 上执行。

work stealing 机制的好处是可以避免线程饥饿，提高 Goroutine 的调度效率。当某个 M 线程的本地队列中没有 Goroutine 可供执行时，它可以从其他 M 线程的队列中偷取 Goroutine 来执行，从而提高整个系统的并发能力和负载均衡性。同时，由于 work stealing 机制的实现比较复杂，因此在高并发场景下可能会增加一些额外的开销，需要谨慎使用。

161. 如何实现 MP 中的 work stealing 机制？

下面给出一个简单的示例代码，演示 GMP 中的 work stealing 机制：

package main
import (
    "fmt"
    "runtime"
    "sync"
    "time"
)
func main() {
    runtime.GOMAXPROCS(2) // 启用两个 P
    var wg sync.WaitGroup
    wg.Add(10)
    for i := 0; i < 10; i++ {
        go func() {
            time.Sleep(time.Second) // 模拟 Goroutine 的耗时操作
            fmt.Println("Goroutine executed.")
            wg.Done()
        }()
    }
    wg.Wait()
}