反应器-第一次为空时停止源

import select
import socket

class Reactor:
    def __init__(self):
        self.readers = []
        self.writers = []
        self.running = False

    def add_reader(self, fd, callback):
        self.readers.append((fd, callback))

    def add_writer(self, fd, callback):
        self.writers.append((fd, callback))

    def run(self):
        self.running = True
        while self.running:
            readable, writable, exceptional = select.select(self.readers, self.writers, self.readers + self.writers)
            for fd, callback in readable:
                callback(fd)
            for fd, callback in writable:
                callback(fd)
            for fd, callback in exceptional:
                callback(fd)
                self.readers.remove((fd, callback))
                self.writers.remove((fd, callback))

    def stop(self):
        self.running = False

def handle_client(sock):
    data = sock.recv(1024)
    if not data:
        sock.close()
        reactor.readers.remove((sock, handle_client))
    else:
        print(f"Received: {data.decode()}")

def main():
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.bind(('localhost', 8080))
    server.listen(5)
    server.setblocking(False)

    reactor = Reactor()
    reactor.add_reader(server, lambda fd: handle_client(fd.accept()[0]))

    reactor.run()

if __name__ == "__main__":
    main()