def run(self):
    with self.condition:
      if len(self.threads) >= self.thread_count:
        return
      thread = self.__TaskLoop(self)
      self.threads.add(thread)
      thread.start()
add a successor to a node
dataset/ETHPy150Open JeremyOT/Toto/toto/tasks.py/TaskQueue.run--crossover with--dataset/ETHPy150Open kakwa/pygraph_redis/pygraph_redis/directed_graph.py/Directed_graph._add_successor