queue_management_thread = executor._queue_management_thread

del executor

# Make sure that all the executor ressources were properly cleaned by

# Make sure that all the executor resources were properly cleaned by

# the shutdown process

queue_management_thread.join()

for p in processes.values():

# extensive testing for deadlock caused by crashes in a pool.

self.executor.shutdown(wait=True)

crash_cases = [

# Check problem occuring while pickling a task in

# Check problem occurring while pickling a task in

# the task_handler thread

(id, (ErrorAtPickle(),), PicklingError, "error at task pickle"),

# Check problem occuring while unpickling a task on workers

# Check problem occurring while unpickling a task on workers

(id, (ExitAtUnpickle(),), BrokenProcessPool,

"exit at task unpickle"),

(id, (ErrorAtUnpickle(),), BrokenProcessPool,

"error at task unpickle"),

(id, (CrashAtUnpickle(),), BrokenProcessPool,

"crash at task unpickle"),

# Check problem occuring during func execution on workers

# Check problem occurring during func execution on workers

(_crash, (), BrokenProcessPool,

"crash during func execution on worker"),

(_exit, (), SystemExit,

"exit during func execution on worker"),

(_raise_error, (RuntimeError, ), RuntimeError,

"error during func execution on worker"),

# Check problem occuring while pickling a task result

# Check problem occurring while pickling a task result

# on workers

(_return_instance, (CrashAtPickle,), BrokenProcessPool,

"crash during result pickle on worker"),

(_return_instance, (ExitAtPickle,), SystemExit,

"exit during result pickle on worker"),

(_return_instance, (ErrorAtPickle,), PicklingError,

"error during result pickle on worker"),

# Check problem occuring while unpickling a task in

# Check problem occurring while unpickling a task in

# the result_handler thread

(_return_instance, (ErrorAtUnpickle,), BrokenProcessPool,

"error during result unpickle in result_handler"),