登录
首页 >  Golang >  Go问答

REST API 中的异步函数调用

来源:stackoverflow

时间:2024-04-23 21:18:31 206浏览 收藏

今天golang学习网给大家带来了《REST API 中的异步函数调用》,其中涉及到的知识点包括等等,无论你是小白还是老手,都适合看一看哦~有好的建议也欢迎大家在评论留言,若是看完有所收获,也希望大家能多多点赞支持呀!一起加油学习~

问题内容

这里我有一个函数,即 returnallarticles,它将被 rest api 调用,该函数返回一个文章列表,并且在该函数内有一个异步函数,即 doneasync 正在被调用。此 aysnc 函数可能需要一些时间来处理其自身的数据。我想要 json 值,即无论该异步函数是否完成,都应该返回所有文章。代码我粘贴在下面

func returnAllArticles(w http.ResponseWriter, r *http.Request){
    fmt.Println("Endpoint Hit: returnAllArticles")
    json.NewEncoder(w).Encode(Articles)
   
        val := DoneAsync()
    fmt.Println("Done is running ...")
    fmt.Println(<- val)

}

func DoneAsync() chan int {
    r := make(chan int)
    fmt.Println("Warming up ...")
    go func() {
        time.Sleep(3 * time.Second)
        r <- 1
        fmt.Println("Done ...")
    }()
    return r
}
func handleRequests() {
    myRouter := mux.NewRouter().StrictSlash(true)
    myRouter.HandleFunc("/articles", returnAllArticles);
   log.Fatal(http.ListenAndServe(":8080",myRouter))
}

但就我而言,在异步函数完成之前,json 值不会返回。我没有获得该异步函数的异步功能。


正确答案


此行将阻塞,直到将值写入 val

fmt.println(<- val)

因此,您的 doneasync 函数创建了一个 goroutine,该 goroutine 继续处理某些内容,并最终写入 val 通道,但调用它的处理程序会等待,直到有内容写入该通道。

如果您希望在执行此处理时发送编码结果,则可以在响应处理程序实现 flusher 时发送,并刷新它:

if f, ok:=w.(http.Flusher); ok {
   f.Flush()
}

到这里,我们也就讲完了《REST API 中的异步函数调用》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>