catch errors in multiple threads and retry

This commit is contained in:
QingQiz 2020-07-21 20:10:38 +08:00
parent c8eef8fb0b
commit c83ca1fc07

View File

@ -530,12 +530,20 @@ def parallel_in_thread(target, params_list, sort, **kwargs):
def action_sort():
while not tasks.empty():
idx, params = tasks.get(block=False)
result.put((idx, target(*params)))
try:
result.put((idx, target(*params)))
except Exception as e:
logging.warn(str(e))
tasks.put((idx, params))
def action_not_sort():
while not tasks.empty():
params = tasks.get(block=False)
result.put(target(*params))
try:
params = tasks.get(block=False)
result.put(target(*params))
except Exception as e:
logging.warn(str(e))
tasks.put(params)
def f():
try: