lisp - 如何检查另一端是否已从单个线程关闭我的套接字流？

Question

usocket FAQ 建议我应该这样做的方法是读取 socket-stream 并检查 end-of-file 结果。这适用于每个套接字有一个事件线程的情况，但它似乎不能满足我试图在同一线程中为多个套接字提供服务的情况。

考虑类似的东西

(defparameter *socket* (socket-listen "127.0.0.1" 123456))
(defparameter *client-connections*
   (list (socket-accept *socket*)
         (socket-accept *socket*)
         (socket-accept *socket*)
         (socket-accept *socket*)))

对于本练习，假设我实际上有四个客户端连接到那里。从一个线程开始为他们提供服务的方式似乎是这样的

(wait-for-input *client-connections*)
(loop for sock in *client-connections*
      for stream = (socket-stream sock)
      when (listen stream)
        do (let ((line (read-line stream nil :eof)))
              (if (eq line :eof)
                  (progn (delete sock *client-connections*)
                         (socket-close sock))
                  (handle sock line))))

除了这不起作用，因为断开连接的套接字仍然返回 nil 给 listen，并尝试从事件的 read没有消息的套接字将阻塞但是 wait-for-intput 在混合中有一个关闭的套接字时立即返回，即使没有其他套接字准备好消息(尽管看起来无法指定导致它返回的套接字)。

在一段时间内没有客户端说话并且第三个客户端断开连接的情况下，似乎没有找到并关闭特定套接字连接的好方法。我必须按顺序读取它们，除了因为 read 在没有输入时阻塞，这将导致线程等待直到前两个客户端都发送消息。

我想到的解决方案，但经过一些确定的谷歌搜索后还没有找到，是(按偏好降序排列):

1. 一个等同于 listen 的函数，如果对目标流的读取将返回 end-of-file 标记，则返回 t . (用这个概念函数替换上面的 listen 会让它的其余部分像写的那样工作)
2. 一个等同于 wait-for-input 的函数，它返回导致其跳闸的已关闭套接字列表。 (在这种情况下，我可以遍历已关闭的套接字列表，使用建议的read 技术检查它们是否确实已关闭，并根据需要关闭/弹出它们)
3. 一个等同于 wait-for-input 的函数，它返回导致它跳闸的第一个关闭的套接字。 (与 #2 相同，但速度较慢，因为它每次迭代最多删除一个非事件连接)
4. 跟踪自从我从每个套接字连接接收到输入后有多久了，并在一段时间不活动后关闭它们。 (无论如何我可能都想这样做，但是只是这样做可能会使一堆死连接保持的时间比必要的时间长得多)
5. 一个尝试从具有即时超时的流中read-char 的函数，如果遇到:eof 则返回t，并且unread-char 任何其他内容(在超时或未读后返回 nil)。 (这是最后的手段，因为它似乎很容易以一种不明显但致命的方式破解)。

此外，如果我以完全错误的方式思考这个问题，也请指出。

Answer 1

事实证明，我提到的选项 2 存在。

wait-for-input 默认返回完整的跟踪连接列表，用于内存管理(据报道有人非常担心cons结果的新列表) , 但它有一个 &key 参数，告诉它只返回有话要说的连接。

(wait-for-input (list conn1 conn2 conn3 conn4) :ready-only t)

是我在那里寻找的东西。这将返回所有就绪的连接，而不仅仅是那些将发出 end-of-file 信号的连接，因此循环仍然需要处理这两种情况。有点像

(loop for sock in (wait-for-input *client-connections* :ready-only t)
      for stream = (socket-stream sock)
      do (let ((line (read-line stream nil :eof)))
            (if (eq line :eof)
                (progn (delete sock *client-connections*)
                       (socket-close sock))
                (handle sock line))))

应该做得很好。