(self, num=0)
| 18 | |
| 19 | class ReceiveQueueThread(threading.Thread, StoppableThread): |
| 20 | def __init__(self, num=0): |
| 21 | threading.Thread.__init__(self, name="ReceiveQueue_%i" %(num)) |
| 22 | self.initStop() |
| 23 | self.name = "ReceiveQueue_%i" % (num) |
| 24 | logger.info("init receive queue thread %i", num) |
| 25 | |
| 26 | def run(self): |
| 27 | while not self._stopped and state.shutdown == 0: |