code: def __init__(self, generator, start=True, maxsize=0):
      self.generator = generator
      self.thread = threading.Thread(target=self._generatorcall)
      self.q = Queue.Queue(maxsize=maxsize)
      self.next = self.__next__
      if start:
          self.thread.start()
  
file_path: PGL/apps/Graph4Rec/env_run/src/datasets/helper.py
imports: import os
  import sys
  import time
  import warnings
  import queue
  import numpy
  import threading
  import collections
label_desc: Use image node_id 1 to create a new AsynchronousGenerator object  with example: obj = AsynchronousGenerator(generator, start, maxsize)