当前位置：首页 > 文章列表 > Golang > Go问答 > 如何在终端应用程序中正确实现 Goroutine

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

来源：stackoverflow 2024-04-25 18:27:33 0浏览收藏

golang学习网今天将给大家带来《如何在终端应用程序中正确实现 Goroutine》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

问题内容

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

    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"))

当我调用此端点时，整个用户界面会冻结，只有在请求完成后我才能继续使用 gui。例如，我尝试在发出请求时在 gui 中包含一个加载框，但发生了冻结，并且在请求完成后才显示加载。

这是 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 函数，但我得到了相同的结果。