def _CreateNewConsumerPool(self, num_processes, num_threads, status_queue):
    processes = []
    task_queue = _NewMultiprocessingQueue()
    task_queues.append(task_queue)

    current_max_recursive_level.value += 1
    if current_max_recursive_level.value > MAX_RECURSIVE_DEPTH:
      raise CommandException('Recursion depth of Apply calls is too great.')
    for _ in range(num_processes):
      recursive_apply_level = len(consumer_pools)
      p = multiprocessing.Process(
          target=self._ApplyThreads,
          args=(num_threads, num_processes, recursive_apply_level,
                status_queue))
      p.daemon = True
      processes.append(p)
      p.start()
    consumer_pool = _ConsumerPool(processes, task_queue)
    consumer_pools.append(consumer_pool)
Allocates an IP address of the range
dataset/ETHPy150Open GoogleCloudPlatform/gsutil/gslib/command.py/Command._CreateNewConsumerPool--crossover with--dataset/ETHPy150Open fp7-ofelia/ocf/vt_manager/src/python/vt_manager/models/Ip4Range.py/Ip4Range.allocateIp