|
|
@@ -6,13 +6,18 @@ q = queue.Queue()
|
|
|
|
|
|
def worker():
|
|
|
while True:
|
|
|
- task = q.get()
|
|
|
- logging.debug(f"Working on {task}")
|
|
|
- job, callback = task
|
|
|
- job()
|
|
|
- callback()
|
|
|
- logging.debug(f"Working on {task} done.")
|
|
|
- q.task_done()
|
|
|
+ try:
|
|
|
+ task = q.get()
|
|
|
+ logging.debug(f"Working on {task}")
|
|
|
+ job, callback = task
|
|
|
+ job()
|
|
|
+ callback()
|
|
|
+ logging.debug(f"Working on {task} done.")
|
|
|
+ q.task_done()
|
|
|
+ except Exception as e:
|
|
|
+ logging.debug("error:", exc_info=e)
|
|
|
+ raise e
|
|
|
+
|
|
|
|
|
|
def init_workers(count=2):
|
|
|
for _ in range(count):
|
