Function RunGenerateIsolinesTasks

tools/topography_generator/generator.cpp:408–446

template <typename ParamsType>
void RunGenerateIsolinesTasks(int left, int bottom, int right, int top, std::string const & srtmPath,
                              ParamsType const & params, long threadsCount, long maxCachedTilesPerThread,
                              bool forceRegenerate)
{
  std::vector<std::unique_ptr<TileIsolinesTask>> tasks;

  CHECK_GREATER(right, left, ());
  CHECK_GREATER(top, bottom, ());

  int tilesRowPerTask = top - bottom;
  int tilesColPerTask = right - left;

  if (tilesRowPerTask * tilesColPerTask <= static_cast<long>(threadsCount))
  {
    tilesRowPerTask = 1;
    tilesColPerTask = 1;
  }
  else
  {
    while (tilesRowPerTask * tilesColPerTask > static_cast<long>(maxCachedTilesPerThread))
      if (tilesRowPerTask > tilesColPerTask)
        tilesRowPerTask = (tilesRowPerTask + 1) / 2;
      else
        tilesColPerTask = (tilesColPerTask + 1) / 2;
  }

  base::ComputationalThreadPool threadPool(threadsCount);

  for (int lat = bottom; lat < top; lat += tilesRowPerTask)
  {
    int const topLat = std::min(lat + tilesRowPerTask - 1, top - 1);
    for (int lon = left; lon < right; lon += tilesColPerTask)
    {
      int const rightLon = std::min(lon + tilesColPerTask - 1, right - 1);
      auto task = std::make_unique<TileIsolinesTask>(lon, lat, rightLon, topLat, srtmPath, &params, forceRegenerate);
      threadPool.SubmitWork([task = std::move(task)]() { task->Do(); });
    }
  }
}
}  // namespace

Generator::Generator(std::string const & srtmPath, long threadsCount, long maxCachedTilesPerThread,