code: def __init__(self, dataset, batch_size, num_process=5):
      self._dataset = dataset
      self._batch_size = batch_size
      self._q = Queue(maxsize=5)
      self._runner_list = []
  
      for i in range(num_process):
          runner = self._get_runner()
          runner.daemon = True
          runner.start()
          self._runner_list.append(runner)
  
imports: from multiprocessing import Process, Queue
label_desc: Use image node_id 1 to create a new Sampler object from inherited base classes: object with example: obj = Sampler(dataset, batch_size, num_process)