resolver.py 文件源码

def one_poll_loop(self):
        if self.futures:
            for (fd, ev) in self.poll.poll(1):
                future = self.futures[fd]
                if ev & select.POLLOUT:
                    if not future.writable():
                        self.poll.modify(fd, select.POLLIN)
                if ev & select.POLLIN:
                    if not future.readable():
                        self.unregister(fd)
                if ev & (select.POLLERR | select.POLLHUP):
                    self.unregister(fd)

        for fd, future in self.futures.items():
            if future.ready():
                self.unregister(fd)