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

StopWatch.createStarted介绍

[英]Provides a started stopwatch for convenience.
[中]为方便起见，提供了启动秒表。

代码示例

代码示例来源：origin: org.apache.commons/commons-lang3

@Test
public void testStopWatchStatic() {
  final StopWatch watch = StopWatch.createStarted();
  assertTrue(watch.isStarted());
}

代码示例来源：origin: org.apache.commons/commons-lang3

final StopWatch watch = StopWatch.createStarted();
watch.suspend();
try {

代码示例来源：origin: opencb/opencga

@Override
public QueryResult<VariantAnnotation> getAnnotation(String name, Query query, QueryOptions options) {
  StopWatch stopWatch = StopWatch.createStarted();
  Iterator<VariantAnnotation> variantAnnotationIterator = annotationIterator(name, query, options);
  List<VariantAnnotation> annotations = new ArrayList<>();
  variantAnnotationIterator.forEachRemaining(annotations::add);
  return new QueryResult<>("getAnnotation", ((int) stopWatch.getTime(TimeUnit.MILLISECONDS)), annotations.size(), -1,
      "", "", annotations);
}

代码示例来源：origin: opencb/opencga

public Query next(int batchSize) {
  Query newQuery;
  if (query == null) {
    newQuery = new Query();
  } else {
    newQuery = new Query(query);
  }
  StopWatch stopWatch = StopWatch.createStarted();
  List<Object> variants = new ArrayList<>(batchSize);
  do {
    // Always execute "next" over variantsIterator, to fail if empty
    variants.add(variantsIterator.next());
  } while (variantsIterator.hasNext() && variants.size() < batchSize);
  newQuery.append(VariantQueryParam.ID.key(), variants);
  logger.info("Get next query: " + stopWatch.getTime(TimeUnit.MILLISECONDS) / 1000.0);
  return newQuery;
}

代码示例来源：origin: opencb/opencga

@Override
public List<Variant> read(int batchSize) {
  StopWatch watch = StopWatch.createStarted();
  List<Variant> variants = new ArrayList<>(batchSize);
  while (variants.size() < batchSize && iterator.hasNext()) {
    variants.add(iterator.next());
  }
  long newTimeFetching = iterator.getTimeFetching(TimeUnit.MILLISECONDS);
  long newTimeConverting = iterator.getTimeConverting(TimeUnit.MILLISECONDS);
  logger.debug("another batch of {} elements read. time: {}ms", variants.size(), watch.getTime());
  logger.debug("time splitted: fetch = {}ms, convert = {}ms",
      newTimeFetching - this.timeFetching,
      newTimeConverting - this.timeConverting);
  this.timeFetching = newTimeFetching;
  this.timeConverting = newTimeConverting;
  return variants;
}

代码示例来源：origin: opencb/opencga

static VariantMongoDBIterator persistentIterator(MongoDBCollection collection, Bson query, Bson projection, QueryOptions options,
                         DocumentToVariantConverter converter) {
  StopWatch watch = StopWatch.createStarted();
  MongoPersistentCursor cursor = new MongoPersistentCursor(collection, query, projection, options);
  VariantMongoDBIterator iterator = new VariantMongoDBIterator(cursor, converter);
  iterator.timeFetching += watch.getNanoTime();
  return iterator;
}

代码示例来源：origin: opencb/opencga

@Override
public QueryResult<AlignmentGlobalStats> stats(Path path, Path workspace) throws Exception {
  StopWatch watch = StopWatch.createStarted();
  FileUtils.checkFile(path);
  FileUtils.checkDirectory(workspace);
  Path statsPath = workspace.resolve(path.getFileName() + ".stats");
  AlignmentGlobalStats alignmentGlobalStats;
  if (statsPath.toFile().exists()) {
    // Read the file of stats
    ObjectMapper objectMapper = new ObjectMapper();
    alignmentGlobalStats = objectMapper.readValue(statsPath.toFile(), AlignmentGlobalStats.class);
  } else {
    BamManager alignmentManager = new BamManager(path);
    alignmentGlobalStats = alignmentManager.stats();
    ObjectMapper objectMapper = new ObjectMapper();
    ObjectWriter objectWriter = objectMapper.typedWriter(AlignmentGlobalStats.class);
    objectWriter.writeValue(statsPath.toFile(), alignmentGlobalStats);
  }
  watch.stop();
  return new QueryResult<>("Get stats", (int) watch.getTime(), 1, 1, "", "", Collections.singletonList(alignmentGlobalStats));
}

代码示例来源：origin: opencb/opencga

@Override
public QueryResult<RegionCoverage> getLowCoverageRegions(Path path, Region region, int minCoverage) throws Exception {
  FileUtils.checkFile(path);
  StopWatch watch = StopWatch.createStarted();
  List<RegionCoverage> regionCoverages = null;
  if (path.toFile().getName().endsWith(".bam")) {
    BamManager bamManager = new BamManager(path);
    regionCoverages = bamManager.getUncoveredRegions(region, minCoverage);
    bamManager.close();
  }
  watch.stop();
  return new QueryResult<>(region.toString(), ((int) watch.getTime()), 1, 1, null, null, regionCoverages);
}

代码示例来源：origin: opencb/opencga

@Override
  public QueryResult<RegionCoverage> coverage(Path path, Region region, int windowSize) throws Exception {
//        QueryOptions options = new QueryOptions();
//        options.put(QueryParams.WINDOW_SIZE.key(), DEFAULT_WINDOW_SIZE);
//        options.put(QueryParams.CONTAINED.key(), false);
//        return coverage(path, workspace, new Query(), options);
    FileUtils.checkFile(path);

    StopWatch watch = StopWatch.createStarted();
    RegionCoverage regionCoverage;
    if (path.toFile().getName().endsWith(".bam")) {
      BamManager bamManager = new BamManager(path);
      regionCoverage = bamManager.coverage(region, windowSize);
      bamManager.close();
    } else {
      regionCoverage = BamUtils.getCoverageFromBigWig(region, windowSize, path);
    }
    watch.stop();
    return new QueryResult<>(region.toString(), ((int) watch.getTime()), 1, 1, null, null, Collections.singletonList(regionCoverage));
  }

代码示例来源：origin: opencb/opencga

@Override
public QueryResult<Long> count(Path path, Query query, QueryOptions options) {
  StopWatch watch = StopWatch.createStarted();
  ProtoAlignmentIterator iterator = iterator(path, query, options);
  long count = 0;
  while (iterator.hasNext()) {
    iterator.next();
    count++;
  }
  watch.stop();
  return new QueryResult<>("Get count", (int) watch.getTime(), 1, 1, "", "", Collections.singletonList(count));
}

代码示例来源：origin: opencb/opencga

public QueryResult<VariantMetadata> getMetadata(Query query, QueryOptions queryOptions, String sessionId)
    throws CatalogException, IOException, StorageEngineException {
  return secure(query, queryOptions, sessionId, engine -> {
    StopWatch watch = StopWatch.createStarted();
    VariantMetadataFactory metadataFactory = new CatalogVariantMetadataFactory(catalogManager, engine.getDBAdaptor(), sessionId);
    VariantMetadata metadata = metadataFactory.makeVariantMetadata(query, queryOptions);
    return new QueryResult<>("getMetadata", ((int) watch.getTime()), 1, 1, "", "", Collections.singletonList(metadata));
  });
}

代码示例来源：origin: Microsoft/ApplicationInsights-Java

@After
public void tearDown() {
  StopWatch sw = StopWatch.createStarted();
  underTest.stop(10, TimeUnit.SECONDS);
  underTest = null;
  System.out.printf("%s.tearDown() took %.3f seconds%n", LocalForwarderTelemetryTransmitterTest.class.getSimpleName(), sw.getTime(TimeUnit.MILLISECONDS) / 1000.0);
}

代码示例来源：origin: com.societegenerale.ci-droid.tasks-consumer/ci-droid-tasks-consumer-services

public void onGitHubPullRequestEvent(PullRequestEvent pullRequestEvent) {
  if (!acceptedPullrequestEventType.contains(pullRequestEvent.getAction())) {
    log.debug("not processing pullRequest event of type {}", pullRequestEvent.getAction());
    return;
  }
  Event techEvent = Event.technical(MonitoringEvents.PULL_REQUEST_EVENT_TO_PROCESS);
  techEvent.addAttribute(REPO, pullRequestEvent.getRepository().getFullName());
  techEvent.addAttribute(PR_NUMBER, String.valueOf(pullRequestEvent.getPrNumber()));
  StopWatch stopWatch = StopWatch.createStarted();
  for (PullRequestEventHandler pullRequestEventHandler : actionHandlers) {
    pullRequestEventHandler.handle(pullRequestEvent);
  }
  stopWatch.stop();
  techEvent.addAttribute("processTime", String.valueOf(stopWatch.getTime()));
  techEvent.publish();
}

代码示例来源：origin: opencb/opencga

public QueryResult<Long> count(Query query) throws StorageEngineException {
  query = preProcessQuery(query, null);
  if (!doQuerySearchManager(query, new QueryOptions(QueryOptions.COUNT, true))) {
    return getDBAdaptor().count(query);
  } else {
    try {
      StopWatch watch = StopWatch.createStarted();
      long count = getVariantSearchManager().count(dbName, query);
      int time = (int) watch.getTime(TimeUnit.MILLISECONDS);
      return new QueryResult<>("count", time, 1, 1, "", "", Collections.singletonList(count));
    } catch (IOException | VariantSearchException e) {
      throw new VariantQueryException("Error querying Solr", e);
    }
  }
}

代码示例来源：origin: opencb/opencga

default QueryResult<VariantFileMetadata> get(int studyId, int fileId, QueryOptions options) throws StorageEngineException {
  StopWatch stopWatch = StopWatch.createStarted();
  Iterator<VariantFileMetadata> iterator;
  try {
    Query query = new Query(VariantFileMetadataQueryParam.FILE_ID.key(), fileId)
        .append(VariantFileMetadataQueryParam.STUDY_ID.key(), studyId);
    iterator = iterator(query, options);
  } catch (IOException e) {
    throw new StorageEngineException("Error reading from VariantFileMetadataDBAdaptor", e);
  }
  VariantFileMetadata metadata = Iterators.getOnlyElement(iterator, null);
  if (metadata != null) {
    return new QueryResult<>("", ((int) stopWatch.getTime(TimeUnit.MILLISECONDS)), 1, 1, null, null,
        Collections.singletonList(metadata));
  } else {
    return new QueryResult<>("", ((int) stopWatch.getTime(TimeUnit.MILLISECONDS)), 0, 0, null, null, Collections.emptyList());
  }
}

代码示例来源：origin: opencb/opencga

@Override
public QueryResult<ReadAlignment> get(Path path, Query query, QueryOptions options) {
  try {
    FileUtils.checkFile(path);
    StopWatch watch = StopWatch.createStarted();
    BamManager bamManager = new BamManager(path);
    Region region = parseRegion(query);
    AlignmentFilters<SAMRecord> alignmentFilters = parseQuery(query);
    AlignmentOptions alignmentOptions = parseQueryOptions(options);
    String queryResultId;
    List<ReadAlignment> readAlignmentList;
    if (region != null) {
      readAlignmentList = bamManager.query(region, alignmentFilters, alignmentOptions, ReadAlignment.class);
      queryResultId = region.toString();
    } else {
      readAlignmentList = bamManager.query(alignmentFilters, alignmentOptions, ReadAlignment.class);
      queryResultId = "Get alignments";
    }
    bamManager.close();
    watch.stop();
    return new QueryResult<>(queryResultId, ((int) watch.getTime()), readAlignmentList.size(), readAlignmentList.size(), null, null,
        readAlignmentList);
  } catch (Exception e) {
    e.printStackTrace();
    return new QueryResult<>();
  }
}

代码示例来源：origin: com.societegenerale.ci-droid.tasks-consumer/ci-droid-tasks-consumer-services

public void onGitHubPushEvent(PushEvent pushEvent) {
  if (shouldNotProcess(pushEvent)) {
    return;
  }
  Event techEvent = Event.technical(PUSH_EVENT_TO_PROCESS);
  techEvent.addAttribute(REPO, pushEvent.getRepository().getFullName());
  StopWatch stopWatch = StopWatch.createStarted();
  List<PullRequest> openPRs = retrieveOpenPrs(pushEvent.getRepository().getFullName());
  List<PullRequest> openPRsWithDefinedMergeabilityStatus = figureOutMergeableStatusFor(openPRs, 0);
  logPrMergeabilityStatus(openPRsWithDefinedMergeabilityStatus);
  for (PushEventOnDefaultBranchHandler pushEventOnDefaultBranchHandler : actionHandlers) {
    try {
      pushEventOnDefaultBranchHandler.handle(pushEvent, openPRsWithDefinedMergeabilityStatus);
    } catch (RuntimeException e) {
      log.warn("exception thrown during event handling by "+pushEventOnDefaultBranchHandler.getClass(),e);
    }
  }
  stopWatch.stop();
  techEvent.addAttribute("processTime", String.valueOf(stopWatch.getTime()));
  techEvent.publish();
}

代码示例来源：origin: opencb/opencga

@Test
public void testSampleIndexDBAdaptor() throws StorageEngineException {
  List<List<Region>> regionLists = Arrays.asList(null, Arrays.asList(new Region("1", 1000, 300000)));
  for (List<Region> regions : regionLists) {
    StopWatch stopWatch = StopWatch.createStarted();
    long actualCount = ((HadoopVariantStorageEngine) variantStorageEngine).getSampleIndexDBAdaptor().count(regions, "S_1", "NA12877", Arrays.asList("0/1", "1/1"));
    Query query = new Query(VariantQueryParam.STUDY.key(), "S_1")
        .append(VariantQueryParam.SAMPLE.key(), "NA12877");
    if (regions != null) {
      query.append(VariantQueryParam.REGION.key(), regions);
    }
    System.out.println("Count indexTable " + stopWatch.getTime(TimeUnit.MILLISECONDS) / 1000.0);
    System.out.println("Count = " + actualCount);
    stopWatch = StopWatch.createStarted();
    long expectedCount = dbAdaptor.count(query).first();
    System.out.println("Count variants   " + stopWatch.getTime(TimeUnit.MILLISECONDS) / 1000.0);
    System.out.println("Count = " + expectedCount);
    System.out.println("-----------------------------------");
    assertEquals(expectedCount, actualCount);
  }
}

代码示例来源：origin: opencb/opencga

@Override
public QueryResult<AlignmentGlobalStats> stats(Path path, Path workspace, Query query, QueryOptions options) throws Exception {
  FileUtils.checkFile(path);
  StopWatch watch = StopWatch.createStarted();
  if (options == null) {
    options = new QueryOptions();
  }
  if (options.size() == 0 && query.size() == 0) {
    return stats(path, workspace);
  }
  Region region = parseRegion(query);
  AlignmentFilters alignmentFilters = parseQuery(query);
  AlignmentOptions alignmentOptions = parseQueryOptions(options);
  BamManager alignmentManager = new BamManager(path);
  AlignmentGlobalStats alignmentGlobalStats = alignmentManager.stats(region, alignmentFilters, alignmentOptions);
  watch.stop();
  return new QueryResult<>("Get stats", (int) watch.getTime(), 1, 1, "", "", Arrays.asList(alignmentGlobalStats));
}

代码示例来源：origin: opencb/opencga

@Test
public void testCohortIterator() throws CatalogException, SolrServerException, IOException {
  QueryOptions queryOptions = new QueryOptions(FLATTENED_ANNOTATIONS, "true");
  queryOptions.put(QueryOptions.INCLUDE, Arrays.asList(CohortDBAdaptor.QueryParams.ID.key(), CohortDBAdaptor.QueryParams.NAME.key(),
      CohortDBAdaptor.QueryParams.STUDY_UID.key(),
      CohortDBAdaptor.QueryParams.TYPE.key(), CohortDBAdaptor.QueryParams.CREATION_DATE.key(), CohortDBAdaptor.QueryParams.STATUS.key(),
      CohortDBAdaptor.QueryParams.RELEASE.key(), CohortDBAdaptor.QueryParams.ANNOTATION_SETS.key(), CohortDBAdaptor.QueryParams.SAMPLE_UIDS.key()));
  MongoDBAdaptorFactory factory = new MongoDBAdaptorFactory(catalogManager.getConfiguration());
  CohortMongoDBAdaptor cohortMongoDBAdaptor = factory.getCatalogCohortDBAdaptor();
  DBIterator<Cohort> cohortIterator = cohortMongoDBAdaptor.iterator(new Query(), queryOptions);
  int i = 0;
  StopWatch stopWatch = StopWatch.createStarted();
  while (cohortIterator.hasNext()) {
    cohortIterator.next();
    i++;
    if (i % 10000 == 0) {
      System.out.println("i: " + i + "; time: " + stopWatch.getTime(TimeUnit.MILLISECONDS));
      stopWatch.reset();
      stopWatch.start();
      return;
    }
  }
}