wss运行一段时间后无法关闭 about nbio

[liangmanlin]

没有使用taskpool，直接在poller里面进行了一次nbiotcp.Write,按道理不会卡死？

[lesismal]

用Shutdown试试。

[lesismal]

提供下可复现的代码

[lesismal]

我最近有点忙，闲了看

[liangmanlin]

复现代码可能要等下周，目前已知就是在nbhttp.Parser.Read里面触发了Parser.Close,导致了死锁，nbhttp默认是用taskpool工作，可能平时不会发生，我是直接在poller里面执行函数

复现过程就是，大量新建wss连接，然后突然关闭客户端

[lesismal]

我想想要不要给bio.Conn多加个mutex给Execute队列单独使用，否则这种io协程上不跨协程直接执行逻辑队列onclose确实不好弄。但poller协程上直接进行逻辑处理要注意避免阻塞比如请求下游http或者rpc或者数据库等其他阻塞操作

[liangmanlin]

目前看只有onclose会这样，我认为可以把onclose放入taskpool运行，一般来说不会有问题，这样改的比较少

[lesismal]

Onclose也要保证顺序，所以是用nbio.Conn.Execute放到Conn队列里去执行，这里默认就是用的taskpool但你定制后没有走协程池了

[lesismal]

直接在engine调用onclose的地方go去执行倒是可以解决onclose本身，但可能还会有其他死锁

[lesismal]

可以测下试试

[lesismal]

你本地在这里加个go试试：
https://github.com/lesismal/nbio/blob/master/poller_epoll.go#L103

[liangmanlin]

好，我试试

[liangmanlin]

跑了几天，问题依旧，可能还有别的地方触发

[liangmanlin]

在websocket.Conn.handleProtocolMessage也会触发close

奇怪，我确定已经在 deleteConn 加了go语句，为何还会死锁

[lesismal]

还是用协程池吧，如果不想协程数量太多，把协程池size设小点就行了

[liangmanlin]

nbio/nbhttp/websocket/conn.go

Line 240 in 9d2ae1d

c.Conn.Close()

把这个改成

go c.Conn.Close()

应该可以解决，考虑到可能破坏原来的设计**，看能不能加一个配置，用户选择是否异步执行？

[lesismal]

这样看上去不太美丽，你们用size较小的协程池会有什么问题吗？

[liangmanlin]

业务只是非常薄的一次wss->tcp转发，用异步处理感觉不划算

[lesismal]

就用默认的协程池可以的不

[lesismal]

如果在线量不是非常大，标准库同步方案延迟更低

[liangmanlin]

嗯，我考虑一下