avoid deadlock when only one active thread remains
This commit is contained in:
parent
ced95da38e
commit
dfe6593968
|
@ -145,6 +145,9 @@ class ConductorWorker:
|
||||||
activecount = threading.active_count()
|
activecount = threading.active_count()
|
||||||
if expectedthreads != activecount:
|
if expectedthreads != activecount:
|
||||||
logging.getLogger("pyexec").fatal("!!! Active/expected running threads count is: %d/%d", activecount, expectedthreads)
|
logging.getLogger("pyexec").fatal("!!! Active/expected running threads count is: %d/%d", activecount, expectedthreads)
|
||||||
|
if activecount == 1:
|
||||||
|
logging.getLogger("pyexec").fatal("!!! Exiting")
|
||||||
|
sys.exit(1)
|
||||||
|
|
||||||
|
|
||||||
def exc(taskType, inputData, startTime, retryCount, status, callbackAfterSeconds, pollCount):
|
def exc(taskType, inputData, startTime, retryCount, status, callbackAfterSeconds, pollCount):
|
||||||
|
|
Loading…
Reference in New Issue