最近的评论

• 评论了主题 如何限制http.HandleFunc并发数量？
  #5楼 @GGXXLL 假设我的limit-handler没写好，不能正常退出或者处理速度过慢，那么当请求快速源源不断到来时，就有可能导致系统内有无数个go-routine。如果不能即时消化这些go-routine可能就会导致内存爆掉了。 不过如果limit-handler写得足够健壮，这个担心应该是多余的:-)
• 评论了主题 如何限制http.HandleFunc并发数量？
  @GGXXLL 感谢指点，我没有描述清我的问题。我看了下源码，我的需求该是无解的。我想要的效果在资源超限时阻止创建go routine，也就是下面代码最后一行不要执行：`go c.serve(connCtx)`。 现在看来就是来了一个请求，只能先执行这行代码创建go routine，进入limit-handler，然后再退出了。 func (srv *Server) Serve(l net.Listener) error { if fn := testHookServerServe; fn != nil { fn(srv, l) // call hook with unwrapped listener } origListener := l l = &onceCloseListener{Listener: l} defer l.Close() if err := srv.setupHTTP2_Serve(); err != nil { return err } if !srv.trackListener(&l, true) { return ErrServerClosed } defer srv.trackListener(&l, false) baseCtx := context.Background() if srv.BaseContext != nil { baseCtx = srv.BaseContext(origListener) if baseCtx == nil { panic("BaseContext returned a nil context") } } var tempDelay time.Duration // how long to sleep on accept failure ctx := context.WithValue(baseCtx, ServerContextKey, srv) for { rw, err := l.Accept() if err != nil { if srv.shuttingDown() { return ErrServerClosed } if ne, ok := err.(net.Error); ok && ne.Temporary() { if tempDelay == 0 { tempDelay = 5 * time.Millisecond } else { tempDelay *= 2 } if max := 1 * time.Second; tempDelay > max { tempDelay = max } srv.logf("http: Accept error: %v; retrying in %v", err, tempDelay) time.Sleep(tempDelay) continue } return err } connCtx := ctx if cc := srv.ConnContext; cc != nil { connCtx = cc(connCtx, rw) if connCtx == nil { panic("ConnContext returned nil") } } tempDelay = 0 c := srv.newConn(rw) c.setState(c.rwc, StateNew, runHooks) // before Serve can return go c.serve(connCtx) } }
• 评论了主题 如何限制http.HandleFunc并发数量？
  #1楼 @GGXXLL @GGXXLL 感谢指点，我没有描述清我的问题。我看了下源码，我的需求该是无解的。我想要的效果在资源超限时阻止创建go routine，也就是下面代码最后一行不要执行：`go c.serve(connCtx)`。 现在看来就是来了一个请求，只能先执行这行代码创建go routine，进入limit-handler，然后再退出了。 func (srv *Server) Serve(l net.Listener) error { if fn := testHookServerServe; fn != nil { fn(srv, l) // call hook with unwrapped listener } origListener := l l = &onceCloseListener{Listener: l} defer l.Close() if err := srv.setupHTTP2_Serve(); err != nil { return err } if !srv.trackListener(&l, true) { return ErrServerClosed } defer srv.trackListener(&l, false) baseCtx := context.Background() if srv.BaseContext != nil { baseCtx = srv.BaseContext(origListener) if baseCtx == nil { panic("BaseContext returned a nil context") } } var tempDelay time.Duration // how long to sleep on accept failure ctx := context.WithValue(baseCtx, ServerContextKey, srv) for { rw, err := l.Accept() if err != nil { if srv.shuttingDown() { return ErrServerClosed } if ne, ok := err.(net.Error); ok && ne.Temporary() { if tempDelay == 0 { tempDelay = 5 * time.Millisecond } else { tempDelay *= 2 } if max := 1 * time.Second; tempDelay > max { tempDelay = max } srv.logf("http: Accept error: %v; retrying in %v", err, tempDelay) time.Sleep(tempDelay) continue } return err } connCtx := ctx if cc := srv.ConnContext; cc != nil { connCtx = cc(connCtx, rw) if connCtx == nil { panic("ConnContext returned nil") } } tempDelay = 0 c := srv.newConn(rw) c.setState(c.rwc, StateNew, runHooks) // before Serve can return go c.serve(connCtx) } }
• 评论了博文 Go使用全局变量要小心闭包
  楼主一本正经的胡说八道 :laughing: