「Go语言面试题」19 - goroutine 为什么比传统线程更适合高并发场景？

// 测试 goroutine 的内存占用
func testGoroutineMemory() {
    var wg sync.WaitGroup
    num := 100000 // 10万个goroutine
    
    for i := 0; i < num; i++ {
        wg.Add(1)
        go func() {
            time.Sleep(time.Second)
            wg.Done()
        }()
    }
    wg.Wait()
    fmt.Println("10万个goroutine创建完成")
}

// 对比：尝试创建大量线程（实际运行可能会失败）
func testThreadMemory() {
    // 注意：这段代码可能无法正常运行，因为线程数可能超过系统限制
    var wg sync.WaitGroup
    num := 10000 // 1万个线程
    
    for i := 0; i < num; i++ {
        wg.Add(1)
        go func() {
            runtime.LockOSThread() // 绑定系统线程
            defer runtime.UnlockOSThread()
            time.Sleep(time.Second)
            wg.Done()
        }()
    }
    wg.Wait()
}

func benchmarkCreation() {
    const count = 10000
    
    // 测试goroutine创建开销
    start := time.Now()
    var wg sync.WaitGroup
    for i := 0; i < count; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
        }()
    }
    wg.Wait()
    goroutineTime := time.Since(start)
    
    // 测试线程创建开销（使用线程池对比）
    start = time.Now()
    pool := tunny.NewFunc(100, func(interface{}) interface{} {
        return nil
    })
    defer pool.Close()
    
    for i := 0; i < count; i++ {
        pool.Process(nil)
    }
    threadPoolTime := time.Since(start)
    
    fmt.Printf("Goroutine创建开销: %v\n", goroutineTime)
    fmt.Printf("线程池任务处理开销: %v\n", threadPoolTime)
}