code: def __init__(self, all_chunk_op_keys: List[str]):
      self._all_chunk_op_keys = set(all_chunk_op_keys)
      self._done_chunk_op_keys = set()
      self._lock = threading.Lock()
  
imports: import threading
  import time
  from typing import List
  import numpy
  from ...None import opcodes
  from ...core.context import get_context
  from ...oscar import ActorNotExist
  from ...serialization.serializables import FieldTypes, KeyField, StringField, DictField, TupleField
  from ...lib.filesystem import open_file
  from ...utils import has_unknown_shape
  from ..datasource import tensor
  from .core import TensorDataStore
label_desc: Use image node_id 1 to create a new _HDF5Container object  with example: obj = _HDF5Container(all_chunk_op_keys)