com.google.common.base.Stopwatch.stop()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(99)

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

Stopwatch.stop介绍

[英]Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this point.
[中]停止秒表。未来的读取将返回到目前为止经过的固定持续时间。

代码示例

代码示例来源：origin: stackoverflow.com

Stopwatch stopwatch = Stopwatch.createStarted();
myCall();
stopwatch.stop(); // optional
System.out.println("Time elapsed for myCall() is "+ stopwatch.elapsed(MILLISECONDS));

代码示例来源：origin: Graylog2/graylog2-server

@Override
public void retain(String indexName, IndexSet indexSet) {
  final Stopwatch sw = Stopwatch.createStarted();
  indices.close(indexName);
  auditEventSender.success(AuditActor.system(nodeId), ES_INDEX_RETENTION_CLOSE, ImmutableMap.of(
      "index_name", indexName,
      "retention_strategy", this.getClass().getCanonicalName()
  ));
  LOG.info("Finished index retention strategy [close] for index <{}> in {}ms.", indexName,
      sw.stop().elapsed(TimeUnit.MILLISECONDS));
}

代码示例来源：origin: thinkaurelius/titan

@Override
  public IDBlock call() {
    Stopwatch running = Stopwatch.createStarted();
    try {
      if (stopRequested) {
        log.debug("Aborting ID block retrieval on partition({})-namespace({}) after " +
            "graceful shutdown was requested, exec time {}, exec+q time {}",
            partition, idNamespace, running.stop(), alive.stop());
        throw new TitanException("ID block retrieval aborted by caller");
      }
      IDBlock idBlock = idAuthority.getIDBlock(partition, idNamespace, renewTimeout);
      log.debug("Retrieved ID block from authority on partition({})-namespace({}), " +
           "exec time {}, exec+q time {}",
           partition, idNamespace, running.stop(), alive.stop());
      Preconditions.checkArgument(idBlock!=null && idBlock.numIds()>0);
      return idBlock;
    } catch (BackendException e) {
      throw new TitanException("Could not acquire new ID block from storage", e);
    } catch (IDPoolExhaustedException e) {
      return ID_POOL_EXHAUSTION;
    }
  }
}

代码示例来源：origin: MovingBlocks/Terasology

public ChunkMesh generateMesh(ChunkView chunkView, int meshHeight, int verticalOffset) {
  PerformanceMonitor.startActivity("GenerateMesh");
  ChunkMesh mesh = new ChunkMesh(bufferPool);
  final Stopwatch watch = Stopwatch.createStarted();
  for (int x = 0; x < ChunkConstants.SIZE_X; x++) {
    for (int z = 0; z < ChunkConstants.SIZE_Z; z++) {
      for (int y = verticalOffset; y < verticalOffset + meshHeight; y++) {
        Block block = chunkView.getBlock(x, y, z);
        if (block != null && block.getMeshGenerator() != null) {
          block.getMeshGenerator().generateChunkMesh(chunkView, mesh, x, y, z);
        }
      }
    }
  }
  watch.stop();
  mesh.setTimeToGenerateBlockVertices((int) watch.elapsed(TimeUnit.MILLISECONDS));
  watch.reset().start();
  generateOptimizedBuffers(chunkView, mesh);
  watch.stop();
  mesh.setTimeToGenerateOptimizedBuffers((int) watch.elapsed(TimeUnit.MILLISECONDS));
  statVertexArrayUpdateCount++;
  PerformanceMonitor.endActivity();
  return mesh;
}

代码示例来源：origin: kairosdb/kairosdb

@Override
public void run()
{
  //System.out.println("DynamicFutureTask.run");
  try
  {
    m_stopwatch.start();
    super.run();
    m_stopwatch.stop();
    m_ingestTimeStats.addValue(m_stopwatch.elapsed(TimeUnit.MICROSECONDS));
  }
  finally
  {
    m_semaphore.release();
  }
}

代码示例来源：origin: google/guava

public void testStop_alreadyStopped() {
 stopwatch.start();
 stopwatch.stop();
 try {
  stopwatch.stop();
  fail();
 } catch (IllegalStateException expected) {
 }
 assertFalse(stopwatch.isRunning());
}

代码示例来源：origin: locationtech/geogig

private void benchmarkIteration(Iterator<RevCommit> commits) {
  NumberFormat numberFormat = NumberFormat.getInstance(Locale.ENGLISH);
  Stopwatch sw = Stopwatch.createStarted();
  sw.reset().start();
  int c = 0;
  while (commits.hasNext()) {
    c++;
    commits.next();
  }
  sw.stop();
  System.err.println("Iterated " + numberFormat.format(c) + " commits in " + sw.toString());
}

代码示例来源：origin: apache/kylin

@Override
  public void finish(CuboidResult result) {
    Stopwatch stopwatch = new Stopwatch().start();
    int nRetries = 0;
    while (!outputQueue.offer(result)) {
      nRetries++;
      long sleepTime = stopwatch.elapsedMillis();
      if (sleepTime > 3600000L) {
        stopwatch.stop();
        throw new RuntimeException(
            "OutputQueue Full. Cannot offer to the output queue after waiting for one hour!!! Current queue size: "
                + outputQueue.size());
      }
      logger.warn("OutputQueue Full. Queue size: " + outputQueue.size() + ". Total sleep time : " + sleepTime
          + ", and retry count : " + nRetries);
      try {
        Thread.sleep(5000L);
      } catch (InterruptedException e) {
        throw new RuntimeException(e);
      }
    }
    stopwatch.stop();
  }
}

代码示例来源：origin: forcedotcom/phoenix

Transaction transaction = null;
List<Event>  events = Lists.newArrayListWithExpectedSize(this.batchSize); 
Stopwatch watch = new Stopwatch().start();
try {
  transaction = channel.getTransaction();
  logger.error(String.format("Time taken to process [%s] events was [%s] seconds",events.size(),watch.stop().elapsedTime(TimeUnit.SECONDS)));
  if( transaction != null ) {
    transaction.close();

代码示例来源：origin: Graylog2/graylog2-server

@Override
public void retain(String indexName, IndexSet indexSet) {
  final Stopwatch sw = Stopwatch.createStarted();
  indices.delete(indexName);
  auditEventSender.success(AuditActor.system(nodeId), ES_INDEX_RETENTION_DELETE, ImmutableMap.of(
      "index_name", indexName,
      "retention_strategy", this.getClass().getCanonicalName()
  ));
  LOG.info("Finished index retention strategy [delete] for index <{}> in {}ms.", indexName,
      sw.stop().elapsed(TimeUnit.MILLISECONDS));
}

代码示例来源：origin: twitter/distributedlog

Stopwatch stopwatch = Stopwatch.createStarted();
try {
  if (null == lastDLSN) {
    reader = FutureUtils.result(dlm.openAsyncLogReader(lastDLSN));
  long elapsedMs = stopwatch.elapsed(TimeUnit.MICROSECONDS);
  openReaderStats.registerSuccessfulEvent(elapsedMs);
  logger.info("It took {} ms to position the reader to transaction id = {}, dlsn = {}",
      lastTxId, lastDLSN);
} catch (IOException ioe) {
  openReaderStats.registerFailedEvent(stopwatch.elapsed(TimeUnit.MICROSECONDS));
  logger.warn("Failed to create reader for stream {} reading from tx id = {}, dlsn = {}.",
      new Object[] { streamName, lastTxId, lastDLSN });
while (true) {
  try {
    stopwatch.start();
    records = FutureUtils.result(reader.readBulk(batchSize));
    long elapsedMicros = stopwatch.stop().elapsed(TimeUnit.MICROSECONDS);
    blockingReadStats.registerSuccessfulEvent(elapsedMicros);
    if (!records.isEmpty()) {

代码示例来源：origin: google/guava

public void testElapsed_multipleSegments() {
 stopwatch.start();
 ticker.advance(9);
 stopwatch.stop();
 ticker.advance(16);
 stopwatch.start();
 assertEquals(9, stopwatch.elapsed(NANOSECONDS));
 ticker.advance(25);
 assertEquals(34, stopwatch.elapsed(NANOSECONDS));
 stopwatch.stop();
 ticker.advance(36);
 assertEquals(34, stopwatch.elapsed(NANOSECONDS));
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
public void close() {
  stopwatch.stop();
  if (stopwatch.elapsed(thresholdUnit) >= threshold) {
    log.info("[{}] execution took {} {}", new Object[] {name, stopwatch.elapsed(reportUnit), niceName(reportUnit)});
  }
}

代码示例来源：origin: JanusGraph/janusgraph

@Override
  public IDBlock call() {
    Stopwatch running = Stopwatch.createStarted();
    try {
      if (stopRequested) {
        log.debug("Aborting ID block retrieval on partition({})-namespace({}) after " +
            "graceful shutdown was requested, exec time {}, exec+q time {}",
            partition, idNamespace, running.stop(), alive.stop());
        throw new JanusGraphException("ID block retrieval aborted by caller");
      }
      IDBlock idBlock = idAuthority.getIDBlock(partition, idNamespace, renewTimeout);
      log.debug("Retrieved ID block from authority on partition({})-namespace({}), " +
           "exec time {}, exec+q time {}",
           partition, idNamespace, running.stop(), alive.stop());
      Preconditions.checkArgument(idBlock!=null && idBlock.numIds()>0);
      return idBlock;
    } catch (BackendException e) {
      throw new JanusGraphException("Could not acquire new ID block from storage", e);
    } catch (IDPoolExhaustedException e) {
      return ID_POOL_EXHAUSTION;
    }
  }
}

代码示例来源：origin: google/guava

public void testStop() {
 stopwatch.start();
 assertSame(stopwatch, stopwatch.stop());
 assertFalse(stopwatch.isRunning());
}

代码示例来源：origin: apache/kylin

@Test
public void createDirectChildrenCacheStressTest() {
  Stopwatch sw = new Stopwatch();
  sw.start();
  Set<Long> cuboidSet = generateMassCuboidSet();
  System.out.println("Time elapsed for creating sorted cuboid list: " + sw.elapsedMillis());
  sw.reset();
  sw.start();
  checkDirectChildrenCacheStressTest(CuboidStatsUtil.createDirectChildrenCache(cuboidSet));
  System.out.println("Time elapsed for creating direct children cache: " + sw.elapsedMillis());
  sw.stop();
}

代码示例来源：origin: jclouds/legacy-jclouds

public void testQueueDeletedRecentlyRetriesWhen60DoesntTry() {
 SQSErrorRetryHandler retry = new SQSErrorRetryHandler(createMock(AWSUtils.class),
    createMock(BackoffLimitedRetryHandler.class), ImmutableSet.<String> of(), 60, 100);
 HttpCommand command = createHttpCommandForFailureCount(60);
 Stopwatch watch = new Stopwatch().start();
 assertFalse(retry.shouldRetryRequestOnError(command, response, error));
 assertEquals(command.getFailureCount(), 61);
 assertTrue(watch.stop().elapsedTime(TimeUnit.MILLISECONDS) < 100);
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  protected void shutDown() throws Exception {
    for (Periodical periodical : periodicals.getAllStoppedOnGracefulShutdown()) {
      LOG.info("Shutting down periodical [{}].", periodical.getClass().getCanonicalName());
      Stopwatch s = Stopwatch.createStarted();

      // Cancel future executions.
      Map<Periodical,ScheduledFuture> futures = periodicals.getFutures();
      if (futures.containsKey(periodical)) {
        futures.get(periodical).cancel(false);

        s.stop();
        LOG.info("Shutdown of periodical [{}] complete, took <{}ms>.",
            periodical.getClass().getCanonicalName(), s.elapsed(TimeUnit.MILLISECONDS));
      } else {
        LOG.error("Could not find periodical [{}] in futures list. Not stopping execution.",
            periodical.getClass().getCanonicalName());
      }
    }
  }
}

代码示例来源：origin: twitter/distributedlog

Stopwatch stopwatch = Stopwatch.createStarted();
try {
  reader = dlm.getInputStream(lastTxId);
  long elapsedMs = stopwatch.elapsed(TimeUnit.MICROSECONDS);
  openReaderStats.registerSuccessfulEvent(elapsedMs);
  logger.info("It took {} ms to position the reader to transaction id {}", lastTxId);
} catch (IOException ioe) {
  openReaderStats.registerFailedEvent(stopwatch.elapsed(TimeUnit.MICROSECONDS));
  logger.warn("Failed to create reader for stream {} reading from {}.", streamName, lastTxId);
while (true) {
  try {
    stopwatch.start();
    record = reader.readNext(nonBlocking);
    if (null != record) {
      long elapsedMicros = stopwatch.stop().elapsed(TimeUnit.MICROSECONDS);
      if (nonBlocking) {
        nonBlockingReadStats.registerSuccessfulEvent(elapsedMicros);

代码示例来源：origin: google/guava

public void testElapsed_notRunning() {
 ticker.advance(1);
 stopwatch.start();
 ticker.advance(4);
 stopwatch.stop();
 ticker.advance(9);
 assertEquals(4, stopwatch.elapsed(NANOSECONDS));
}

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

stopwatch

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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