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

Timer.<init>介绍

[英]Creates a new Timer using an ExponentiallyDecayingReservoir and the default Clock.
[中]使用指数缓存库和默认时钟创建新计时器。

代码示例

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

@Override
public Timer newMetric() {
  return new Timer();
}

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

@Override
public Timer newMetric() {
  return new Timer();
}

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

@Override
 public com.codahale.metrics.Timer load(String key) {
  Timer timer = new Timer(new ExponentiallyDecayingReservoir());
  metricRegistry.register(key, timer);
  return timer;
 }
}

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

@Override
  public Timer load(String key) {
    Timer timer = new Timer(new ExponentiallyDecayingReservoir());
    metricRegistry.register(key, timer);
    return timer;
  }
});

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

/**
 * Creates a MessageTimerMonitor using the provided clock
 *
 * @param clock the clock used to measure the process time of each message
 */
public MessageTimerMonitor(Clock clock) {
  allTimer = new Timer(new ExponentiallyDecayingReservoir(), clock);
  successTimer = new Timer(new ExponentiallyDecayingReservoir(), clock);
  failureTimer = new Timer(new ExponentiallyDecayingReservoir(), clock);
  ignoredTimer = new Timer(new ExponentiallyDecayingReservoir(), clock);
}

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

UserTaskManager(long sessionExpiryMs,
        long maxActiveUserTasks,
        long completedUserTaskRetentionTimeMs,
        int maxCachedCompletedUserTasks,
        Time time,
        UUIDGenerator uuidGenerator) {
 _sessionToUserTaskIdMap = new HashMap<>();
 _activeUserTaskIdToFuturesMap = new LinkedHashMap<>();
 _completedUserTaskIdToFuturesMap = new LinkedHashMap<UUID, UserTaskInfo>() {
  @Override
  protected boolean removeEldestEntry(Map.Entry<UUID, UserTaskInfo> eldest) {
   return this.size() > maxCachedCompletedUserTasks;
  }
 };
 _sessionExpiryMs = sessionExpiryMs;
 _maxActiveUserTasks = maxActiveUserTasks;
 _completedUserTaskRetentionTimeMs = completedUserTaskRetentionTimeMs;
 _time = time;
 _uuidGenerator = uuidGenerator;
 _userTaskScannerExecutor.scheduleAtFixedRate(new UserTaskScanner(),
                        USER_TASK_SCANNER_INITIAL_DELAY_SECONDS,
                        USER_TASK_SCANNER_PERIOD_SECONDS,
                        TimeUnit.SECONDS);
 _successfulRequestExecutionTimer = new HashMap<>();
 EndPoint.cachedValues().forEach(e -> _successfulRequestExecutionTimer.put(e, new Timer()));
}

代码示例来源：origin: aol/micro-server

private Timer timer (String name) {
    return registry.timer(name, () -> new Timer(new SlidingTimeWindowArrayReservoir(configuration.getTimerIntervalSeconds(), TimeUnit.SECONDS)));
  }
}

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

@Override
public Integer call() throws Exception {
  loggerForCleaner.debug("Beginning log cleanup");
  int total = 0;
  final Timer.Context ctx = new Timer().time();
  for (final Log kafkaLog : JavaConversions.asJavaIterable(logManager.allLogs())) {
    if (kafkaLog.config().compact()) continue;
    loggerForCleaner.debug("Garbage collecting {}", kafkaLog.name());
    total += cleanupExpiredSegments(kafkaLog) +
        cleanupSegmentsToMaintainSize(kafkaLog) +
        cleanupSegmentsToRemoveCommitted(kafkaLog);
  }
  loggerForCleaner.debug("Log cleanup completed. {} files deleted in {} seconds",
      total,
      NANOSECONDS.toSeconds(ctx.stop()));
  return total;
}

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

this.queuedTaskTimeMaxSize = queuedTaskTimeMaxSize;
this.queuedTaskTimeMaxAge = queuedTaskTimeMaxAge;
this.taskCreateAndRunTimer = new Timer(new SlidingTimeWindowReservoir(timerWindowSize, TimeUnit.MINUTES));

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

@Test
public void validatePNAImplementationsMatch() {
  LocalAssignment la = new LocalAssignment("Topology1", null);
  PortAndAssignment pna = new PortAndAssignmentImpl(1, la);
  PortAndAssignment tpna = new TimePortAndAssignment(pna, new Timer());
  assertTrue(pna.equals(tpna));
  assertTrue(tpna.equals(pna));
  assertTrue(pna.hashCode() == tpna.hashCode());
}

代码示例来源：origin: sixt/ja-micro

public void reset() {
  successTimer = new Timer();
  failureTimer = new Timer();
}

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

recordProcessRateMeter.mark(3l);
Timer totalDurationTimer = new Timer();
totalDurationTimer.update(1, TimeUnit.SECONDS);
totalDurationTimer.update(2, TimeUnit.SECONDS);

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

recordProcessRateMeter.mark(3l);
Timer totalDurationTimer = new Timer();
totalDurationTimer.update(1, TimeUnit.SECONDS);
totalDurationTimer.update(2, TimeUnit.SECONDS);

代码示例来源：origin: uber/chaperone

Counter testCounter0 = new Counter();
Meter testMeter0 = new Meter();
Timer testTimer0 = new Timer();
HelixKafkaMirrorMakerMetricsReporter.get().registerMetric("testCounter0", testCounter0);
HelixKafkaMirrorMakerMetricsReporter.get().registerMetric("testMeter0", testMeter0);

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

@Override
  public com.codahale.metrics.Timer load(String key) throws Exception {
    com.codahale.metrics.Timer timer
        = new com.codahale.metrics.Timer(new ExponentiallyDecayingReservoir());
    metricRegistry.register(key, timer);
    return timer;
  }
}

代码示例来源：origin: org.apache.hive/hive-common

@Override
 public com.codahale.metrics.Timer load(String key) {
  Timer timer = new Timer(new ExponentiallyDecayingReservoir());
  metricRegistry.register(key, timer);
  return timer;
 }
}

代码示例来源：origin: kite-sdk/kite

@Override
public Timer newMetric() {
 return new Timer(new SlidingTimeWindowReservoir(window, windowUnit));
}
@Override

代码示例来源：origin: allegro/hermes

@Before
public void setUp() {
  tempDir = Files.createTempDir();
  when(cachedTopic.getTopic()).thenReturn(topic);
  when(cachedTopic.startBrokerLatencyTimers()).thenReturn(new StartedTimersPair(new Timer(), new Timer()));
  when(topicsCache.getTopic(topic.getQualifiedName())).thenReturn(Optional.of(cachedTopic));
  when(producer.isTopicAvailable(cachedTopic)).thenReturn(true);
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

public Timer timer(MetricName name)
{
  Timer timer = register(name, new Timer(new DecayingEstimatedHistogramReservoir()));
  registerMBean(timer, name.getMBeanName());
  return timer;
}

代码示例来源：origin: apache/jackrabbit-oak

@Test
public void timerContext() throws Exception{
  VirtualClock clock = new VirtualClock();
  Timer time = new Timer(new ExponentiallyDecayingReservoir(), clock);
  TimerStats timerStats = new TimerImpl(time);
  TimerStats.Context context = timerStats.time();
  clock.tick = TimeUnit.SECONDS.toNanos(314);
  context.close();
  assertEquals(1, time.getCount());
  assertEquals(TimeUnit.SECONDS.toNanos(314), time.getSnapshot().getMax());
}