如何在终端应用程序中正确实现 goroutine

Question

我正在尝试在终端中创建一个 HTTP 请求接口，您可以在其中传递一些数据（url、响应正文等），然后我发出请求并在某处显示数据。我正在尝试在 goroutine 中执行请求，并显示通道给我的结果。当我执行 quick 请求时，这是不可能注意到的，但我创建了一个简单的节点端点来测试计算量大的端点：

    app.use(express.json())
    
    app.get("/", (req, res) => {     
         new Promise(resolve => {
             setTimeout(() => resolve(), 3000)
         }).then(() => res.status(200).json({message: "OK"}))
        .catch(err => res.status(500).json({error: err.message}))
    })
   
    app.listen(4000, () => console.log("Server up"))

当我调用此端点时，整个 ui 冻结，只有在请求完成后我才能继续使用 GUI。比如我在请求的时候尝试在GUI处添加一个loading框，但是出现卡顿，请求完成后才显示loading。

这是 httpRequest 函数的代码

func httpRequest(url, method string, body []byte, results chan Result) {
    client := &http.Client{}
    req, err := http.NewRequest(method, url, bytes.NewBuffer(body))
    req.Header.Add("content-type", "application/json")
    if err != nil {
        results <- Result{err: err}
    }

    res, err := client.Do(req)
    if err != nil {
        results <- Result{err: err}
    }

    defer res.Body.Close()

    r := Result{
        method: res.Request.Method,
        url:    res.Request.URL.String(),
        path:   res.Request.URL.Path,
        proto:  res.Proto,
        status: res.Status,
        header: res.Header,
    }

    b, err := io.ReadAll(res.Body)
    if err != nil {
        results <- Result{err: err}
    }

    r.body = string(b)
    results <- r
}

它将在 processRequest 函数上调用：

func processRequest(g *ui.Gui, v *ui.View) error {
    method_view, err := g.View("method")
    if err != nil {
        return err
     }
     method_view.Clear()
     fmt.Fprintln(method_view, "loading...")

    
     // GET ALL REQUEST DATA HERE...


    out, err := g.View("res-output")
    if err != nil {
        return err
    }

    r := make(chan Result, 1)
    start := time.Now()

    switch active_method {
    case 0:
        go httpRequest(api_url, "GET", nil, r)
    case 1:
        go httpRequest(api_url, "POST", request_body_data, r)
    case 2:
        go httpRequest(api_url, "DELETE", request_body_data, r)
    case 3:
        go httpRequest(api_url, "PUT", request_body_data, r)
    }

    result := <-r
    if result.err != nil {
        fmt.Fprintf(out, "Error: %s\n", result.err.Error())
        return nil
    }
    fmt.Fprintf(out, "Time: %f s\n", time.Since(start).Seconds())
    fmt.Fprintln(out, formatResponse(result))

    history_view, err := g.View("history")
    if err != nil {
        return err
    }

    history_item := fmt.Sprintf("%s %s %s\n", result.method, result.url, result.status)
    fmt.Fprintln(history_view, history_item)

    close(r)

    method_view.Clear()
    fmt.Fprintln(method_view, methods[active_method]) // CLEAR THE LOADING FROM TOP AND REWRITE REQUEST METHOD

    return nil
}

我能否实现一种行为，即在发出请求时我仍然可以弄乱 UI？我还尝试创建另一个通道 done 来通知 processRequest 函数，但我得到了相同的结果。

Answer 1

您当前代码的问题在于，当您同时发出请求时，您在等待结果时阻塞 result := <-r。这否定了在 go-routine 中运行ning 请求的意义，因为您在此期间没有做任何事情（例如处理 UI 事件）。

您可以按照在 go-routine 中处理响应的方式构建您的代码，而不仅仅是请求，然后您的应用程序可以正常使用并且响应可以同时更新 UI请求的响应将在未来的某个时间点收到。

换句话说，processRequest 在 go-routine 中应该是运行而不是 httpRequest。

如何在终端应用程序中正确实现 goroutine

How to correctly implement a goroutine in terminal application

terminal

user-interface

http

go