这是一个创建于 277 天前的主题，其中的信息可能已经有所发展或是发生改变。
// 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 277 天前
lis.Accept()是阻塞的
|
 |
2
dhb233 277 天前
会创建啊，如果请求处理完了，goroutine 也会销毁
|
 |
3
lsk569937453 277 天前
这个位置就是要不停的创建的 goroutine ，以保证后面的请求不会被未处理完的请求阻塞。
|
 |
4
Vegetable 277 天前
当然是会不停创建的。
每个连接一个 goroutine ，数量取决于同时存在的连接数量。 |
 |
5
yifeia 277 天前  1
accept 一个创建一个，只要 ServeConn 不阻塞，那 goroutine 执行完了就释放了,问题不大.
|
 |
6
Cola98 277 天前
会不停创建，或者做一个简单的实验，你把这一段 for{
go xxx } 抽出来看下 |
 |
7
hingle 277 天前
在 go 上一行打印一下，就知道会不会了。
|
 |
8
guonaihong 276 天前
因为 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 276 天前
本来就是不停创建啊。但是要上面执行了才会到下面啊，没连接创个啥
|
Select Language