class_docstr: Manages the communication between this process and the worker processes.
  
  The manager is run in a local thread.
  
  Args:
      executor: A reference to the ProcessPoolExecutor that owns
          this thread. A weakref will be own by the manager as well as
          references to internal objects used to introspect the state of
          the executor.
class_docstr_tok: ["Manages","the","communication","between","this","process","and","the","worker","processes",".","The","manager","is","run","in","a","local","thread",".","Args",":","executor",":","A","reference","to","the","ProcessPoolExecutor","that","owns","this","thread",".","A","weakref","will","be","own","by","the","manager","as","well","as","references","to","internal","objects","used","to","introspect","the","state","of","the","executor","."]
code: def process_result_item(self, result_item):
      # Process the received a result_item. This can be either the PID of a
      # worker that exited gracefully or a _ResultItem
  
      if isinstance(result_item, int):
          # Clean shutdown of a worker using its PID
          # (avoids marking the executor broken)
          assert self.is_shutting_down()
          p = self.processes.pop(result_item)
          p.join()
          if not self.processes:
              self.join_executor_internals()
              return
      else:
          # Received a _ResultItem so mark the future as completed.
          work_item = self.pending_work_items.pop(
              result_item.work_id, None
          )
          # work_item can be None if another process terminated (see above)
          if work_item is not None:
              if result_item.exception:
                  work_item.future.set_exception(result_item.exception)
              else:
                  work_item.future.set_result(result_item.result)
  
imports: import os
  from concurrent.futures import _base
  import queue
  import multiprocessing
  import multiprocessing.connection
  from multiprocessing.queues import Queue
  import threading
  import weakref
  from functools import partial
  import itertools
  import sys
  from traceback import format_exception
label_desc: Use image node_id 5 for calling the _ExecutorManagerThread obj's underlying member method code with example usage: obj.process_result_item(result_item) without return types