code: def __init__(self):
      self.lock = threading.Lock()
      self._reset()
  
file_path: horovod/horovod/spark/common/cache.py
imports: import collections
  import contextlib
  import threading
label_desc: Use image node_id 1 to create a new TrainingDataCache object from inherited base classes: object with example: obj = TrainingDataCache()