2

对于初学者，我使用了 Twisted 和 SocketServer 以及 ForkMixIn、ThreadMixIn 并尝试了“线程池”recepies。

但是，我想在 Python 中做一些特别的工作。

一点背景。以前我用 C 编写了一个简单的 TCP 守护程序，它会绑定到一个套接字并监听它，然后多次预分叉 X，然后将 serversocket desc 传递给所有分叉，每个人都会非常非常愉快地接受客户端。

我检查了我非常喜欢的基于“select/poll”的异步。我唯一的不满是，我可以通过分叉几次来获得一点 CPU 不受限制，以利用多 CPU 机器，并希望通过调度获得最好的结果。

我不能让它为我的生活工作。只有 1 个实例可以接受连接，所有其他实例只是在处理连接时抛出异常，“不能通过 Empty 进行迭代”。

这甚至可行吗？我检查了很多，但我找不到任何用于分叉异步调度程序的代码（哭）

谢谢！

更新 1：（根据要求进行完整追溯）

error: uncaptured python exception, closing channel <__main__.EchoServer listening 0.0.0.0:8001 at 0x2ad4880c93f8> (<type 'exceptions.TypeError'>:'NoneType' /python2.6/asyncore.py|readwrite|99] [/usr/local/python2.6.9/lib/python2.6/asyncore.py|handle_read_event|408] [./6py-server.py|handle_accept|87])

总是发生在接受中，无论我是否在 asyncore.loop 之前分叉，等等。

更新 2: (full source) pastebined source

4

1 回答 1

2

您应该使用代码标记进行回溯，否则会显示混乱并且我们看不到异常类型。

但我相信它是TypeError: 'NoneType' object is not iterable因为self.accept()可以返回None。原因是多个进程可以获得监听套接字的读取事件，但只有一个可以接受它。其余进程将收到EWOULDBLOCK错误，该错误被捕获，但随后它返回None而不是连接地址对。

handle_accept()退货时立即更改您的accept()退货None。

于 2009-11-11T06:33:48.647 回答