(self)
| 234 | class PriceWorkerThread(threading.Thread): |
| 235 | |
| 236 | def __init__(self): |
| 237 | threading.Thread.__init__(self) |
| 238 | self.name = "PriceWorker" |
| 239 | self.queue = queue.Queue() |
| 240 | self.wait = {} |
| 241 | self.running = True |
| 242 | pyfalog.debug("Initialize PriceWorkerThread.") |
| 243 | |
| 244 | def run(self): |
| 245 | queue = self.queue |