V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
The Go Programming Language
http://golang.org/
Go Playground
Go Projects
Revel Web Framework
mingyuewandao
V2EX  ›  Go 编程语言

在 for 中使用 go 关键字,为什么不会不停创建 goroutine?

  •  
  •   mingyuewandao · 255 天前 · 2507 次点击
    这是一个创建于 255 天前的主题,其中的信息可能已经有所发展或是发生改变。
    // 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)
    	}
    }
    

    https://github.com/geektutu/7days-golang/blob/cf3644382101dc13e7fd92e8f5c66cabc51bcd3b/gee-rpc/day1-codec/server.go#L143

    9 条回复    2024-02-22 13:55:48 +08:00
    sunny352787
        1
    sunny352787  
       255 天前
    lis.Accept()是阻塞的
    dhb233
        2
    dhb233  
       255 天前
    会创建啊,如果请求处理完了,goroutine 也会销毁
    lsk569937453
        3
    lsk569937453  
       255 天前
    这个位置就是要不停的创建的 goroutine ,以保证后面的请求不会被未处理完的请求阻塞。
    Vegetable
        4
    Vegetable  
       255 天前
    当然是会不停创建的。
    每个连接一个 goroutine ,数量取决于同时存在的连接数量。
    yifeia
        5
    yifeia  
       255 天前   ❤️ 1
    accept 一个创建一个,只要 ServeConn 不阻塞,那 goroutine 执行完了就释放了,问题不大.
    Cola98
        6
    Cola98  
       255 天前
    会不停创建,或者做一个简单的实验,你把这一段 for{
    go xxx
    }
    抽出来看下
    hingle
        7
    hingle  
       255 天前
    在 go 上一行打印一下,就知道会不会了。
    guonaihong
        8
    guonaihong  
       254 天前
    因为 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
    yc8332
        9
    yc8332  
       254 天前
    本来就是不停创建啊。但是要上面执行了才会到下面啊,没连接创个啥
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   1749 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 19ms · UTC 16:33 · PVG 00:33 · LAX 09:33 · JFK 12:33
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.