[Golang]一个非典型的GoRoutine的错误
发布时间:2020-12-16 18:45:15 所属栏目:大数据 来源:网络整理
导读:?? 在不少golang入门的文章上,用并发的例子一般是这样写的; package mainimport ( "fmt" "time" ) func main() { messages := make(chan int ) go func() { time.Sleep(time.Second * 3 ) messages - 1 }() go func() { time.Sleep(time.Second * 2 ) mess
??
在不少golang入门的文章上,用并发的例子一般是这样写的; package main
import (
"fmt"
"time" ) func main() { messages := make(chan int) go func() { time.Sleep(time.Second * 3) messages <- 1 }() go func() { time.Sleep(time.Second * 2) messages <- 2 }() go func() { time.Sleep(time.Second * 1) messages <- 3 }() go func() { for i := range messages { fmt.Println(i) } }() time.Sleep(time.Second * 5) }
我之前的项目,也一直是这样写。今天和群里的讨论了下,才发觉,这个写法其实是比较丑陋的。 其实可以通过这个去实现。 package main
import (
"fmt"
"io/ioutil"
"log"
"net/http"
"sync" ) func main() { urls := []string{ "http://www.reddit.com/r/aww.json","http://www.reddit.com/r/funny.json","http://www.reddit.com/r/programming.json",} jsonResponses := make(chan string) var wg sync.WaitGroup wg.Add(len(urls)) for _,url := range urls { go func(url string) { defer wg.Done() res,err := http.Get(url) if err != nil { log.Fatal(err) } else { defer res.Body.Close() body,err := ioutil.ReadAll(res.Body) if err != nil { log.Fatal(err) } else { jsonResponses <- string(body) } } }(url) } go func() { for response := range jsonResponses { fmt.Println(response) } }() wg.Wait() }
这个更简单,而且也更方便使用。性能方面,应该比chan要好点。 我之前的一个案例是,client发一个http request过来, 服务器收到请求,然后同时开N个go routine去处理,然后每个处理完成后,通过chan 进行传递给主线程,主线程判断chan的是否接收完成所有的请求,然后再响应。 就是用的第一种方法。 今天根据群里面体的建议,重构了下。使用list来处理每个用户请求。 比如,有个全局Map变量: map[int]list,每个请求创建一个巍峨唯一的随机数或者sessionId,然后每个go rouine处理完后,根据sessionid去查找对应的list,插入数据。 可以利用list来实现异步队列的机制,避免锁。 所以特地在这记录下来,当然各位新人的参考。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |