Method init

deps/v8/tools/testrunner/local/pool.py:202–213

Args: num_workers: Number of worker processes to run in parallel. heartbeat_timeout: Timeout in seconds for waiting for results. Each time the timeout is reached, a heartbeat is signalled and timeout is reset. notify_function: Callable called to signal some events li

(self, num_workers=1, heartbeat_timeout=1, notify_function=None)

      self.done_queue = Queue()

  def init(self, num_workers=1, heartbeat_timeout=1, notify_function=None):
    """
    Args:
      num_workers: Number of worker processes to run in parallel.
      heartbeat_timeout: Timeout in seconds for waiting for results. Each time
          the timeout is reached, a heartbeat is signalled and timeout is reset.
      notify_function: Callable called to signal some events like termination. The
          event name is passed as string.
    """
    self.num_workers = num_workers
    self.heartbeat_timeout = heartbeat_timeout
    self.notify = notify_function or (lambda x: x)

  def add_jobs(self, jobs):
    self.add(jobs)