Golang 异步和 CPU 使用率

Question

我正在学习 Go 并发，我的期望是使用 goroutines 和通道应该增加并发性。该程序需要几毫秒才能完成。但是随着负载的增加，尽管有大量的 CPU 空闲，但执行时间会不断增加。

我正在向下面的程序发送 1200 QPS/TPS 以分析请求到响应的时间，我发现程序的整体执行时间随着时间的推移而增加。此外，CPU 使用率约为 3-6%。

当我将 QPS 增加到 100,000 时，程序的执行时间增加到秒（从最初的毫秒）。但 CPU 使用率保持在 8-9%。

那么为什么程序不使用其他 90-94% 的可用 CPU 并更快地完成程序的执行？

ulimit -n 是 2000000。

package main

import (
    "fmt"
    "github.com/valyala/fasthttp"
    "strings"
    "sync"
)

func total(in chan int, out chan int) {
    res := 0
    for iter := range in {
        res += iter
    }
    out <- res // sends back the result
}

func check() {

    ch := make(chan int)
    rch := make(chan int)
    go total(ch, rch)
    ch <- 1
    ch <- 2
    ch <- 3
    close(ch)       // this will end the loop in the total function
    result := <-rch // waits for total to give the result
    fmt.Println("Total is ", result)
}

func main() {
    var wg sync.WaitGroup
    wg.Add(1)

    go func() {
        m := func(ctx *fasthttp.RequestCtx) {

            maingetpath := ctx.Path()
            urlPart := strings.Split(string(maingetpath), "/")
            func := urlPart[1]
            switch string(func) {
            case "white":
                check()
            default:
                ctx.Error("not found", fasthttp.StatusNotFound)
            }
        }

        fasthttp.ListenAndServe(":8080", m)
        defer wg.Done()
    }()

    wg.Wait()
}

Answer 1

我不确定您在这个小服务器上到底想做什么。

1) 您正在创建一个 WaitGroup 并向其添加 1，调用匿名 go 例程，然后在 main 中等待，这将您的 main 移动到匿名函数中。

2) 让我们看看你在 check 和 total 函数中做了什么：

func total(in chan int, out chan int) {
    res := 0
    // this will just pull the value, and then wait till the next value 
    // is pushed... till you close the "in" channel
    for iter := range in {
        res += iter
    }
    out <- res // sends back the result
}

func check() {

    ch := make(chan int)
    rch := make(chan int)
    go total(ch, rch)
    // we are pushing this value into a unbuffered channel...
    ch <- 1  // this gets pushed and waits until it is pulled in the total function 
    ch <- 2  // this gets pushed and waits until it is pulled in the total function 
    ch <- 3  // this gets pushed and waits until it is pulled in the total function 
    close(ch)       // this will end the loop in the total function
    result := <-rch // waits for total to give the result
    fmt.Println("Total is ", result)
} 

请帮助我了解当它完全同步时如何使用任何并发？

也许如果你在 go 例程中调用 check 会更有效率，但对我来说仍然没有任何意义。