com.bc.ceres.core.ProgressMonitor.worked()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(96)

本文整理了Java中com.bc.ceres.core.ProgressMonitor.worked()方法的一些代码示例，展示了ProgressMonitor.worked()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ProgressMonitor.worked()方法的具体详情如下：
包路径：com.bc.ceres.core.ProgressMonitor
类名称：ProgressMonitor
方法名：worked

ProgressMonitor.worked介绍

暂无

代码示例

代码示例来源：origin: bcdev/beam

@Override
public void tileComputed(Object eventSource, TileRequest[] requests, PlanarImage image, int tileX, int tileY,
             Raster raster) {
  semaphore.release();
  pm.worked(1);
}

代码示例来源：origin: bcdev/beam

@Override
public void tileComputed(Object eventSource, TileRequest[] requests, PlanarImage image, int tileX, int tileY,
             Raster raster) {
  for (PlanarImage planarImage : images) {
    if (image != planarImage) {
      BeamLogManager.getSystemLogger().finest(String.format("Scheduling tile x=%d/%d y=%d/%d for %s",
                                 tileX + 1, tileCountX, tileY + 1, tileCountY, planarImage));
      planarImage.getTile(tileX, tileY);
    }
    pm.worked(1);
  }
  semaphore.release();
}

代码示例来源：origin: bcdev/beam

@Override
void setUpRows(ProgressMonitor pm) {
  pm.beginTask("Exporting pin data as csv-file...", pins.size());
  for (Placemark pin : pins) {
    for (List<Band> bandList : variablesList) {
      if (!bandList.isEmpty()) {
        rows.add(setUpRow(pin, bandList));
      }
    }
    pm.worked(1);
  }
  pm.done();
}

代码示例来源：origin: bcdev/beam

@Override
  public Map<String, Product> findProducts(String path, ProgressMonitor pm) {
    final File[] files = listFiles(path);
    Map<String, Product> result = new HashMap<String, Product>();
    pm.beginTask("Scanning for products...", files.length);
    try {
      for (File file : files) {
        if (!file.isDirectory()) {
          addProductToResult(result, file);
        }
        pm.worked(1);
      }
    } finally {
      pm.done();
    }
    return result;
  }
},

代码示例来源：origin: bcdev/beam

/**
 * Scans recursivley for resources in the location given by the constructor.
 * Afterwards you can retrieve the resource by the multiple getter methods
 */
public void scan(ProgressMonitor pm) {
  pm.beginTask("Scanning for resources...", scanLocations.length);
  for (int i = 0; i < scanLocations.length; i++) {
    URL scanLocation = scanLocations[i];
    ArrayList<URL> resourceUrls = new ArrayList<URL>();
    collectResources(scanLocation, relPath, resourceUrls);
    resourcesMap.putAll(splitResourceUrls(scanLocation, relPath, resourceUrls));
    pm.worked(1);
  }
}

代码示例来源：origin: bcdev/beam

private List<Product> getAllProducts(ProgressMonitor pm) {
  List<Product> result = new ArrayList<Product>();
  pm.beginTask("Scanning product locations ...", productLocationList.size());
  try {
    for (ProductLocation productLocation : productLocationList) {
      if (pm.isCanceled()) {
        break;
      }
      for (Product product : productLocation.getProducts(ProgressMonitor.NULL).values()) {
        result.add(product);
      }
      pm.worked(1);
    }
  } finally {
    pm.done();
  }
  return result;
}

代码示例来源：origin: bcdev/beam

private void executeRowBandColumn(ProgressMonitor pm) {
  for (int tileY = 0; tileY < tileCountY; tileY++) {
    for (final PlanarImage image : images) {
      for (int tileX = 0; tileX < tileCountX; tileX++) {
        checkForCancelation(pm);
        /////////////////////////////////////////////////////////////////////
        //
        // Note: GPF pull-processing is triggered here!!!
        //
        image.getTile(tileX, tileY);
        //
        /////////////////////////////////////////////////////////////////////
        pm.worked(1);
      }
    }
  }
}

代码示例来源：origin: bcdev/beam

private static long processSlice(SpatialBinner spatialBinner, ProgressMonitor progressMonitor,
                 float[] superSamplingSteps, MultiLevelImage maskImage, MultiLevelImage[] varImages,
                 Product product, Rectangle sliceRect) {
  final ObservationSlice observationSlice = new ObservationSlice(varImages, maskImage, product, superSamplingSteps, sliceRect, spatialBinner.getBinningContext());
  long numObservations = spatialBinner.processObservationSlice(observationSlice);
  progressMonitor.worked(1);
  return numObservations;
}

代码示例来源：origin: bcdev/beam

private void addTimeSeriesProductToVisat(TimeSeriesAssistantModel assistantModel, ProgressMonitor pm) {
  pm.beginTask("Creating Time Series", 50);
  final ProductLocationsPaneModel locationsModel = assistantModel.getProductLocationsModel();
  pm.worked(1);
  final VariableSelectionPaneModel variablesModel = assistantModel.getVariableSelectionModel();
  pm.worked(1);
  final AbstractTimeSeries timeSeries = TimeSeriesFactory.create(assistantModel.getTimeSeriesName(),
      locationsModel.getProductLocations(),
      variablesModel.getSelectedVariableNames());
  pm.worked(42);
  ProductManager productManager = VisatApp.getApp().getProductManager();
  Product tsProduct = timeSeries.getTsProduct();
  productManager.addProduct(tsProduct);
  pm.worked(6);
}

代码示例来源：origin: bcdev/beam

public boolean exportMetadata(final PrintWriter out, ProgressMonitor pm) {
  pm.beginTask("Export Metadata", 1);
  try {
    writeHeaderLine(out, metadataTable);
    writeAttributes(out, rootElement);
    pm.worked(1);
  } finally {
    pm.done();
  }
  return true;
}

代码示例来源：origin: senbox-org/snap-desktop

public boolean exportMetadata(final PrintWriter out, ProgressMonitor pm) {
  pm.beginTask("Export Metadata", 1);
  try {
    writeHeaderLine(out);
    writeAttributes(out, rootElement);
    pm.worked(1);
  } finally {
    pm.done();
  }
  return true;
}

代码示例来源：origin: bcdev/beam

public static FeatureCollection<SimpleFeatureType, SimpleFeature> loadShapefileForProduct(File file,
                                             Product product,
                                             FeatureCrsProvider crsProvider, ProgressMonitor pm) throws IOException {
  pm.beginTask("Loading Shapefile", 100);
  try {
    FeatureCollection<SimpleFeatureType, SimpleFeature> featureCollection = loadFeatureCollectionFromShapefile(file);
    pm.worked(10);
    return clipFeatureCollectionToProductBounds(featureCollection, product, crsProvider, pm);
  } finally {
    pm.done();
  }
}

代码示例来源：origin: bcdev/beam

private PixelIter createPixelIter(Rectangle rectangle, ProgressMonitor pm) {
  final Tile[] sourceTiles = new Tile[sourceBands.length];
  try {
    pm.beginTask("Extracting data points...", sourceBands.length);
    for (int i = 0; i < sourceBands.length; i++) {
      sourceTiles[i] = getSourceTile(sourceBands[i], rectangle);
      pm.worked(1);
    }
  } finally {
    pm.done();
  }
  return new PixelIter(sourceTiles, roi);
}

代码示例来源：origin: bcdev/beam

private PixelIter createPixelIter(Rectangle rectangle, ProgressMonitor pm) {
  final Tile[] sourceTiles = new Tile[sourceBands.length];
  try {
    pm.beginTask("Extracting data points...", sourceBands.length);
    for (int i = 0; i < sourceBands.length; i++) {
      sourceTiles[i] = getSourceTile(sourceBands[i], rectangle);
      pm.worked(1);
    }
  } finally {
    pm.done();
  }
  return new PixelIter(sourceTiles, roi);
}

代码示例来源：origin: senbox-org/s2tbx

@Override
public void computeTileStack(Map<Band, Tile> targetTiles, Rectangle targetRectangle, ProgressMonitor pm) throws OperatorException {
  Rectangle srcRec = getSourceRectangle(targetRectangle, pixelWindow);
  if (!containsTileValidData(srcRec)) {
    setInvalidTargetSamples(targetTiles);
    return;
  }
  Map<String, Tile> sourceTiles = new HashMap<>();
  sourceTiles.putAll(getSourceTiles(reflectanceBandNames, srcRec, borderExt));
  sourceTiles.putAll(getSourceTiles(InstrumentConsts.GEOM_NAMES, srcRec, borderExt));
  sourceTiles.putAll(getSourceTiles(auxRasterDataNodeNames, srcRec, borderExt));
  for (int y = targetRectangle.y; y < targetRectangle.y + targetRectangle.height; y++) {
    checkForCancellation();
    for (int x = targetRectangle.x; x < targetRectangle.x + targetRectangle.width; x++) {
      processSuperPixel(sourceTiles, x, y, targetTiles);
    }
    pm.worked(1);
  }
  pm.done();
}

代码示例来源：origin: bcdev/beam

private synchronized void writeLevelImage(RenderedImage levelImage, File levelDir, ProgressMonitor pm) throws IOException {
  if (!ensureDir(levelDir)) {
    return;
  }
  try {
    pm.beginTask("Writing image", levelImage.getNumXTiles() * levelImage.getNumYTiles());
    final ImageHeader imageHeader = new ImageHeader(levelImage, "raw");
    imageHeader.store(new FileWriter(new File(levelDir, "image.properties")), null);
    for (int y = 0; y < levelImage.getNumYTiles(); y++) {
      for (int x = 0; x < levelImage.getNumXTiles(); x++) {
        writeTile(levelImage, x, y, levelDir);
        pm.worked(1);
      }
    }
  } finally {
    pm.done();
  }
}

代码示例来源：origin: senbox-org/s1tbx

private IfgStack[] setupIfgStack(CplxContainer[] cplxContainers, ProgressMonitor pm) {
  // construct pairs from data in containers
  IfgStack[] ifgStack = new IfgStack[numOfImages];
  IfgPair[][] ifgPair = new IfgPair[numOfImages][numOfImages];
  pm.beginTask("Computing...", numOfImages);
  for (int i = 0; i < numOfImages; i++) {
    CplxContainer master = cplxContainers[i];
    for (int j = 0; j < numOfImages; j++) {
      CplxContainer slave = cplxContainers[j];
      ifgPair[i][j] = new IfgPair(master, slave);
    }
    ifgStack[i] = new IfgStack(master, ifgPair[i]);
    ifgStack[i].meanCoherence();
    pm.worked(1);
  }
  pm.done();
  return ifgStack;
}

代码示例来源：origin: senbox-org/snap-desktop

@Override
protected Void doInBackground(ProgressMonitor pm) throws Exception {
  pm.beginTask("Computing pixel values...", -1);
  AbstractButton runButton = getButton(ID_OK);
  runButton.setEnabled(false);
  try {
    GPF.createProduct("PixEx", parameterMap, ioForm.getSourceProducts());
    pm.worked(1);
  } finally {
    pm.done();
  }
  return null;
}

代码示例来源：origin: bcdev/beam

@Override
protected Void doInBackground(ProgressMonitor pm) throws Exception {
  pm.beginTask("Computing pixel values...", -1);
  AbstractButton runButton = getButton(ID_OK);
  runButton.setEnabled(false);
  try {
    GPF.createProduct("PixEx", parameterMap, ioForm.getSourceProducts());
    pm.worked(1);
  } finally {
    pm.done();
  }
  return null;
}

代码示例来源：origin: bcdev/beam

public static FeatureCollection<SimpleFeatureType, SimpleFeature> clipFeatureCollectionToProductBounds(FeatureCollection<SimpleFeatureType, SimpleFeature> featureCollection, Product product, FeatureCrsProvider crsProvider, ProgressMonitor pm) {
  final CoordinateReferenceSystem targetCrs = ImageManager.getModelCrs(product.getGeoCoding());
  final Geometry clipGeometry = createGeoBoundaryPolygon(product);
  pm.worked(10);
  CoordinateReferenceSystem featureCrs = featureCollection.getSchema().getCoordinateReferenceSystem();
  if (featureCrs == null) {
    featureCrs = crsProvider.getFeatureCrs(product);
  }
  return FeatureUtils.clipCollection(featureCollection,
                    featureCrs,
                    clipGeometry,
                    DefaultGeographicCRS.WGS84,
                    null,
                    targetCrs,
                    SubProgressMonitor.create(pm, 80));
}

内容来源于网络，如有侵权，请联系作者删除！

ProgressMonitor

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com