thread.py 文件源码

def run(self):
        self.before_actions()

        # Make non-blocking so self.stop has effect
        self.sock.setblocking(0)

        while not self.stopped:
            try:
                self.action()

            except socket.error as error:
                if error.args[0] == errno.EWOULDBLOCK:
                    # No data available, wait a bit
                    time.sleep(0.2)
                    continue

                # Might be connection error
                self.stop()
                self.on_error()

        self.after_actions()
        self.sock.close()