code: def __init__(self):
      self.lock = _threading.RLock()
      self.future = None
      self.result = None
      self.pending = None
  
file_path: mpi4py/src/mpi4py/futures/util.py
imports: import collections
  import functools
  import threading
  from .None import _base
label_desc: Use image node_id 1 to create a new _Collect object  with example: obj = _Collect()