             # Mark the process pool broken so that submits fail right now.             executor = executor_reference()             if executor is not None:                 executor._broken = True                 executor._shutdown_thread = True                 executor = None             # All futures in flight must be marked failed             for work_id, work_item in pending_work_items.items():                 work_item.future.set_exception(                     BrokenProcessPool(                         "A process in the process pool was "                         "terminated abruptly while the future was "                         "running or pending."                     ))                 # Delete references to object. See issue00000                 del work_item             pending_work_items.clear()             # Terminate remaining workers forcibly: the queues or their             # locks may be in a dirty state and block forever.             for p in processes.values():                 p.terminate()             shutdown_worker()             return         ...  