// Accept accepts connections on the listener and serves requests
// for each incoming connection.
func (server *Server) Accept(lis net.Listener) {
for {
conn, err := lis.Accept()
if err != nil {
log.Println("rpc server: accept error:", err)
return
}
// 这里有问题:这里会不会不停创建 goroutine?
go server.ServeConn(conn)
}
}
1
sunny352787 307 天前
lis.Accept()是阻塞的
|
2
dhb233 307 天前
会创建啊,如果请求处理完了,goroutine 也会销毁
|
3
lsk569937453 307 天前
这个位置就是要不停的创建的 goroutine ,以保证后面的请求不会被未处理完的请求阻塞。
|
4
Vegetable 307 天前
当然是会不停创建的。
每个连接一个 goroutine ,数量取决于同时存在的连接数量。 |
5
yifeia 307 天前 1
accept 一个创建一个,只要 ServeConn 不阻塞,那 goroutine 执行完了就释放了,问题不大.
|
6
Cola98 307 天前
会不停创建,或者做一个简单的实验,你把这一段 for{
go xxx } 抽出来看下 |
7
hingle 307 天前
在 go 上一行打印一下,就知道会不会了。
|
8
guonaihong 306 天前
因为 list.Accpet 只有新的连接过来,才会停止阻塞,所以这种写法的 go 程的个数等于连接 net.Conn 的个数。
另外聊个题外话,创建大量的 go 程,新版本 go 的 runtime 里面已经做了复用和优化。性能开销没有想象中那么大。 做过一个实验,使用 https://github.com/antlabs/quickws 这个 websocket 库,创建 100w 个 go 程,内存占用大约是 7.67GB 左右,8w tps 并发,50%的时延是 511.62ms -------------------------------------------------------------- BenchType : BenchEcho Framework : quickws TPS : 86326 EER : 413.65 Min : -1ns Avg : 573.50ms Max : 1.44s TP50 : 511.62ms TP75 : 705.19ms TP90 : 715.05ms TP95 : 718.11ms TP99 : 721.15ms Used : 49.70s Total : 5000000 Success : 4290729 Failed : 709271 Conns : 1000000 Concurrency: 50000 Payload : 1024 CPU Min : 120.52% CPU Avg : 208.70% CPU Max : 231.77% MEM Min : 7.67G MEM Avg : 7.67G MEM Max : 7.67G |
9
yc8332 306 天前
本来就是不停创建啊。但是要上面执行了才会到下面啊,没连接创个啥
|