python - 如何从处理程序中退出异步调度程序？

Question

我在文档中找不到这个，但我是如何在asyncore.loop()不使用信号的情况下突破的？

Answer 1

在查看源代码后很快就解决了。感谢文档直接链接到源！

您可以简单地从应用程序中引发一个ExitNow异常，该异常退出循环。

使用EchoHandler文档中的示例，我已将其修改为在接收数据时立即退出。

class EchoHandler(asyncore.dispatcher_with_send):

    def handle_read(self):
        data = self.recv(8192)
        if data:
            raise asyncore.ExitNow('Server is quitting!')

另外，请记住，ExitNow如果您在内部使用它，您的应用程序不会引发问题。这是我的一些来源：

def run(config):
    instance = LockServer(config)
    try:
        asyncore.loop()
    except asyncore.ExitNow, e:
        print e

Answer 2

当没有连接时，异步循环也会退出，因此您可以关闭连接。如果您有多个连接正在进行，那么您可以使用 asyncore.close_all()。

Answer 3

试试这个：

服务器的一类（扩展 asyncore.dispatcher）：

class Server(asyncore.dispatcher):

    def __init__(self, port):
        asyncore.dispatcher.__init__(self)

        self.host = socket.gethostname()
        self.port = port

        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((self.host, self.port))
        self.listen(5)
        print "[Server] Listening on {h}:{p}".format(h=self.host, p=self.port)

    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print "[ServerSocket] We got a connection from {a}".format(a=addr)
            SocketHandler(sock)

用于管理服务器的线程的另一个类（扩展线程）...检查 run() 方法，我们在其中调用 asyncore.loop()：

class ServerThread(threading.Thread):
    def __init__(self, port):
        threading.Thread.__init__(self)
        self.server = Server(port)

    def run(self):
        asyncore.loop()

    def stop(self):
        self.server.close()
        self.join()

现在启动服务器：

# This is the communication server, it is going to listen for incoming connections, it has its own thread:
s = ServerThread(PORT)
s.start()               # Here we start the thread for the server
print "Server is ready..."
print "Is ServerThread alive? {t}".format(t=str(s.is_alive()))
raw_input("Press any key to stop de server now...")
print "Trying to stop ServerThread..."
s.stop()
print "The server will die in 30 seconds..."

您会注意到服务器不会立即死亡......但它会优雅地死亡

Answer 4

另一种方法是使用 asyncore.loop 调用的 count 参数。然后，您可以将 asyncore.loop 包装在其他逻辑中：

while(i_should_continue()):
    asyncore.loop(count=1)

这不会立即停止打开的连接，或过早超时。但这可能是件好事？我在启动监听服务器时使用它。