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

Timer.update介绍

[英]Adds a recorded duration.
[中]添加记录的持续时间。

代码示例

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

@Override
  public void durationMicros(long time) {
    timer.update(time, TimeUnit.MICROSECONDS);
  }
};

代码示例来源：origin: com.zaxxer/HikariCP

/** {@inheritDoc} */
@Override
public void recordConnectionAcquiredNanos(final long elapsedAcquiredNanos)
{
 connectionObtainTimer.update(elapsedAcquiredNanos, TimeUnit.NANOSECONDS);
}

代码示例来源：origin: spotify/helios

@Override
public void updateTimer(final String name, final long duration, final TimeUnit timeUnit) {
 registry.timer(prefix + name).update(duration, timeUnit);
}

代码示例来源：origin: apache/incubator-gobblin

@Override
 public Timer apply(@Nonnull Timer input) {
  input.update(duration, unit);
  return input;
 }
});

代码示例来源：origin: io.dropwizard.metrics/metrics-core

/**
 * Adds a recorded duration.
 *
 * @param duration the length of the duration
 * @param unit     the scale unit of {@code duration}
 */
public void update(long duration, TimeUnit unit) {
  update(unit.toNanos(duration));
}

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

@Override
  public void update(long duration, TimeUnit unit) {
    super.update(duration, unit);
    if (duration >= 0) {
      hdrHistogram.update(unit.toNanos(duration));
    }
  }
}

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

@Override
public void updateTimer(String name, long duration, TimeUnit unit) {
  String key = name;
  try {
    timersLock.lock();
    Timer timer = timers.get(key);
    timer.update(duration, unit);
  } catch (ExecutionException e) {
    throw new IllegalStateException("Error retrieving timer " + name + " from the metric registry ", e);
  } finally {
    timersLock.unlock();
  }
}

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

private void recordEsMetrics(JestResult jestResult, @Nullable TimeRange range) {
  esTotalSearchesCounter.inc();
  final long tookMs = tookMsFromSearchResult(jestResult);
  esRequestTimer.update(tookMs, TimeUnit.MILLISECONDS);
  if (range != null) {
    esTimeRangeHistogram.update(TimeRanges.toSeconds(range));
  }
}

代码示例来源：origin: apache/incubator-gobblin

@Override
public void update(long duration, TimeUnit unit) {
 super.update(duration, unit);
 if (this.parentTimer.isPresent()) {
  this.parentTimer.get().update(duration, unit);
 }
}

代码示例来源：origin: io.dropwizard.metrics/metrics-core

/**
 * Updates the timer with the difference between current and start time. Call to this method will
 * not reset the start time. Multiple calls result in multiple updates.
 *
 * @return the elapsed time in nanoseconds
 */
public long stop() {
  final long elapsed = clock.getTick() - startTime;
  timer.update(elapsed, TimeUnit.NANOSECONDS);
  return elapsed;
}

代码示例来源：origin: linkedin/cruise-control

private synchronized void checkActiveUserTasks() {
 Iterator<Map.Entry<UUID, UserTaskInfo>> iter = _activeUserTaskIdToFuturesMap.entrySet().iterator();
 while (iter.hasNext()) {
  Map.Entry<UUID, UserTaskInfo> entry = iter.next();
  if (isActiveUserTasksDone(entry.getKey())) {
   LOG.info("UserTask {} is complete and removed from active tasks list", entry.getKey());
   _successfulRequestExecutionTimer.get(entry.getValue().endPoint()).update(entry.getValue().executionTimeNs(), TimeUnit.NANOSECONDS);
   _completedUserTaskIdToFuturesMap.put(entry.getKey(), entry.getValue());
   iter.remove();
  }
 }
}

代码示例来源：origin: apache/incubator-gobblin

private void updateTimers() {
 for(Timer timer : this.timers) {
  timer.update(this.random.nextInt(1000), TimeUnit.SECONDS);
 }
}

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

private void trackOverhead(long overhead1, long overhead2) {
  if (corePlugin.isInternalMonitoringActive()) {
    overhead2 = System.nanoTime() - overhead2;
    metricRegistry.timer(internalOverheadMetricName).update(overhead2 + overhead1, NANOSECONDS);
  }
}

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

@Override
public void notifyGetTimeNanos(long nanos) {
  if (timeGet) {
    registry.timer(getMetricName).update(nanos, TimeUnit.NANOSECONDS);
  } else {
    registry.meter(getMetricName).mark();
  }
}

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

public void updateRpc(CallStats stats) {
 this.callTimer.update(stats.getCallTimeMs(), TimeUnit.MILLISECONDS);
 this.reqHist.update(stats.getRequestSizeBytes());
 this.respHist.update(stats.getResponseSizeBytes());
}

代码示例来源：origin: apache/incubator-gobblin

private void onStart(long startTime) {
  Long queueTime = queuedTasks.remove(this.underlyingTask.getTaskId());
  long workUnitCreationTime = this.underlyingTask.getTaskContext().getTaskState().getPropAsLong(ConfigurationKeys.WORK_UNIT_CREATION_TIME_IN_MILLIS, 0);
  long timeInQueue = startTime - queueTime;
  long timeSinceWorkUnitCreation = startTime - workUnitCreationTime;
  taskCreateAndRunTimer.update(timeSinceWorkUnitCreation, TimeUnit.MILLISECONDS);
  LOG.debug(String.format("Task %s started. Saving queued time of %d ms to history.", underlyingTask.getTaskId(), timeInQueue));
  queuedTaskTimeHistorical.putIfAbsent(System.currentTimeMillis(), timeInQueue);
  runningTaskCount.inc();
 }
}

代码示例来源：origin: fengjiachun/Jupiter

@Override
public void operationSuccess(JChannel channel) throws Exception {
  if (METRIC_NEEDED) {
    long duration = SystemClock.millisClock().now() - request.timestamp();
    MetricsHolder.processingTimer.update(duration, TimeUnit.MILLISECONDS);
  }
}

代码示例来源：origin: fengjiachun/Jupiter

@Override
public void operationSuccess(JChannel channel) throws Exception {
  if (METRIC_NEEDED) {
    long duration = SystemClock.millisClock().now() - request.timestamp();
    MetricsHolder.processingTimer.update(duration, TimeUnit.MILLISECONDS);
  }
}

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

/** Update call stats for non-critical-path methods */
private void updateRpcGeneric(MethodDescriptor method, CallStats stats) {
 final String methodName = method.getService().getName() + "_" + method.getName();
 getMetric(DRTN_BASE + methodName, rpcTimers, timerFactory)
   .update(stats.getCallTimeMs(), TimeUnit.MILLISECONDS);
 getMetric(REQ_BASE + methodName, rpcHistograms, histogramFactory)
   .update(stats.getRequestSizeBytes());
 getMetric(RESP_BASE + methodName, rpcHistograms, histogramFactory)
   .update(stats.getResponseSizeBytes());
}

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

private void updateTimers(int numberOfTimers) {
  for (int i = 0; i < numberOfTimers; i++) {
    metricRegistry.timer(name("timer").tag("number", Integer.toString(i)).build()).update((long) (Math.random() * 1000), TimeUnit.MILLISECONDS);
  }
}