queueasyncthread.py 文件源码

def run(self):
        while not self._stop:
            asyncore.poll(timeout=0.1)

        if self.nf_queue_started:
            self.printDebug("Stopping QueueAsyncThread ...")
            self.printDebug("Unbind nf_queue")
            try:
                self.q.unbind(AF_INET6)
                self.printDebug("Close nf_queue {}".format(self.queue_number))
                self.q.close()
            except:
                pass
            self.nf_queue_started=False
            self.printDebug("QueueAsyncThread stopped")