当前位置: > > > > 如何获取 goroutine 的运行结果?
如何获取 goroutine 的运行结果?
来源:stackoverflow
2024-04-20 22:00:37
0浏览
收藏
IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天米云给大家整理了《如何获取 goroutine 的运行结果?》,聊聊,我们一起来看看吧!
问题内容
在其他语言中,我可以同时运行多个任务并在相应的变量中获取每个任务的结果。
例如在 js 中:
getapi1()
.then( res => console.debug("result 1: ", res) )
getapi2()
.then( res => console.debug("result 2: ", res) )
getapi3()
.then( res => console.debug("result 3: ", res) )
而且我确切地知道哪个函数的执行结果在哪个变量中。
python asyncio 中也是如此:
task1 = asyncio.create_task(getapi1) task2 = asyncio.create_task(getapi2) result1 = await task1 result2 = await task2
我是 go 语言的新手。所有指南都说要使用带有 goroutine 的通道。
但是我不明白,当我从频道中读取内容时,如何确定哪个消息与哪个结果匹配?
resultsChan := make(chan map)
go getApi1(resultsChan)
go getApi2(resultsChan)
go getApi3(resultsChan)
for {
result, ok := <- resultsChan
if ok == false {
break
} else {
// HERE
fmt.Println(result) // How to understand which message the result of what API request?
}
}
正确答案
如果同一个通道要将所有 getapin 函数的结果传达给 main,并且您希望以编程方式确定每个结果的来源,则只需向通道元素类型添加专用字段即可。下面,我声明了一个名为 result 的自定义结构类型,其中包含一个名为 orig 的字段,正是出于此目的。
package main
import (
"fmt"
"sync"
)
type origin int
const (
unknown origin = iota
api1
api2
api3
)
type result struct {
orig origin
data string
}
func getapi1(c chan result) {
res := result{
orig: api1,
data: "some value",
}
c <- res
}
func getapi2(c chan result) {
res := result{
orig: api2,
data: "some value",
}
c <- res
}
func getapi3(c chan result) {
res := result{
orig: api3,
data: "some value",
}
c <- res
}
func main() {
results := make(chan result, 3)
var wg sync.waitgroup
wg.add(3)
go func() {
defer wg.done()
getapi1(results)
}()
go func() {
defer wg.done()
getapi2(results)
}()
go func() {
defer wg.done()
getapi3(results)
}()
go func() {
wg.wait()
close(results)
}()
for res := range results {
fmt.printf("%#v\n", res)
}
}
()
可能的输出(结果的顺序不确定):
883473553817
无论如何,我不会关注;你的问题根本不是一个很好的反思用例。 ,
文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《如何获取 goroutine 的运行结果?》文章吧,也可关注米云公众号了解相关技术文章。
