code: def __init__(self, dataset, q, generate_batch):
      self._q = q
      self._generate_batch = generate_batch
      self._dataset = dataset
      super(_Sampler, self).__init__()
  
file_path: openrec/openrec/tf1/utils/samplers/sampler.py
imports: from multiprocessing import Process, Queue
label_desc: Use image node_id 1 to create a new _Sampler object from inherited base classes: Process with example: obj = _Sampler(dataset, q, generate_batch)