Java Timer类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.netflix.spectator.api.Timer类的典型用法代码示例。如果您正苦于以下问题：Java Timer类的具体用法？Java Timer怎么用？Java Timer使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Timer类属于com.netflix.spectator.api包，在下文中一共展示了Timer类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: processGcEvent

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
private void processGcEvent(GarbageCollectionNotificationInfo info) {
  GcEvent event = new GcEvent(info, jvmStartTime + info.getGcInfo().getStartTime());
  gcLogs.get(info.getGcName()).add(event);
  if (LOGGER.isDebugEnabled()) {
    LOGGER.debug(event.toString());
  }

  // Update pause timer for the action and cause...
  Id eventId = (isConcurrentPhase(info) ? CONCURRENT_PHASE_TIME : PAUSE_TIME)
    .withTag("action", info.getGcAction())
    .withTag("cause", info.getGcCause());
  Timer timer = Spectator.globalRegistry().timer(eventId);
  timer.record(info.getGcInfo().getDuration(), TimeUnit.MILLISECONDS);

  // Update promotion and allocation counters
  updateMetrics(info.getGcName(), info.getGcInfo());

  // Notify an event listener if registered
  if (eventListener != null) {
    try {
      eventListener.onComplete(event);
    } catch (Exception e) {
      LOGGER.warn("exception thrown by event listener", e);
    }
  }
}

开发者ID:Netflix，项目名称:spectator，代码行数:27，代码来源:GcLogger.java

示例2: testRecord

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testRecord() {
  String[] tagValue = new String[] { "default" };
  Timer timer = factory.timer(factory.createId("testRecord",
          Collections.singleton(new TestTagFactory(tagValue))));

  timer.record(42, TimeUnit.MILLISECONDS);
  Assert.assertEquals("testRecord:tag=default", timer.id().toString());
  Assert.assertEquals(timer.count(), 1L);
  Assert.assertEquals(42000000L, timer.totalTime());

  tagValue[0] = "value2";
  Assert.assertEquals("testRecord:tag=value2", timer.id().toString());
  Assert.assertEquals(0L, timer.count());
  Assert.assertEquals(0L, timer.totalTime());
}

开发者ID:Netflix，项目名称:spectator，代码行数:17，代码来源:DefaultPlaceholderTimerTest.java

示例3: testRecordCallableException

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testRecordCallableException() throws Exception {
  Timer timer = factory.timer(factory.createId("testRecordCallableException"));
  clock.setMonotonicTime(100L);
  boolean seen = false;
  try {
    timer.record(() -> {
      clock.setMonotonicTime(500L);
      throw new Exception("foo");
    });
  } catch (Exception e) {
    seen = true;
  }
  Assert.assertTrue(seen);
  Assert.assertEquals(1L, timer.count());
  Assert.assertEquals(400L, timer.totalTime());
}

开发者ID:Netflix，项目名称:spectator，代码行数:18，代码来源:DefaultPlaceholderTimerTest.java

示例4: testRecordRunnableException

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testRecordRunnableException() throws Exception {
  Timer timer = factory.timer(factory.createId("testRecordRunnableException"));
  clock.setMonotonicTime(100L);
  Exception expectedExc = new RuntimeException("foo");
  Exception actualExc = null;
  try {
    timer.record(() -> {
      clock.setMonotonicTime(500L);
      throw expectedExc;
    });
  } catch (Exception e) {
    actualExc = e;
  }
  Assert.assertSame(expectedExc, actualExc);
  Assert.assertEquals(1L, timer.count());
  Assert.assertEquals(timer.totalTime(), 400L);
}

开发者ID:Netflix，项目名称:spectator，代码行数:19，代码来源:DefaultPlaceholderTimerTest.java

示例5: testMeasure

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testMeasure() {
  Timer timer = factory.timer(factory.createId("testMeasure"));
  timer.record(42, TimeUnit.MILLISECONDS);
  clock.setWallTime(3712345L);
  for (Measurement m : timer.measure()) {
    Assert.assertEquals(m.timestamp(), 3712345L);
    if (m.id().equals(timer.id().withTag(Statistic.count))) {
      Assert.assertEquals(1.0, m.value(), 0.1e-12);
    } else if (m.id().equals(timer.id().withTag(Statistic.totalTime))) {
      Assert.assertEquals(42e6, m.value(), 0.1e-12);
    } else {
      Assert.fail("unexpected id: " + m.id());
    }
  }
}

开发者ID:Netflix，项目名称:spectator，代码行数:17，代码来源:DefaultPlaceholderTimerTest.java

示例6: testRecordCallableException

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testRecordCallableException() throws Exception {
  Timer t = newTimer("foo");
  clock.setMonotonicTime(100L);
  boolean seen = false;
  try {
    t.record((Callable<Integer>) () -> {
      clock.setMonotonicTime(500L);
      throw new RuntimeException("foo");
    });
  } catch (Exception e) {
    seen = true;
  }
  Assert.assertTrue(seen);
  Assert.assertEquals(t.count(), 1L);
  Assert.assertEquals(t.totalTime(), 400L);
}

开发者ID:Netflix，项目名称:spectator，代码行数:18，代码来源:ServoTimerTest.java

示例7: testRecordRunnableException

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testRecordRunnableException() throws Exception {
  Timer t = newTimer("foo");
  clock.setMonotonicTime(100L);
  boolean seen = false;
  try {
    t.record((Runnable) () -> {
      clock.setMonotonicTime(500L);
      throw new RuntimeException("foo");
    });
  } catch (Exception e) {
    seen = true;
  }
  Assert.assertTrue(seen);
  Assert.assertEquals(t.count(), 1L);
  Assert.assertEquals(t.totalTime(), 400L);
}

开发者ID:Netflix，项目名称:spectator，代码行数:18，代码来源:ServoTimerTest.java

示例8: totalOfSquaresOverflow

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void totalOfSquaresOverflow() {
  final long seconds = 10;
  final long nanos = TimeUnit.SECONDS.toNanos(seconds);
  final BigInteger s = new BigInteger("" + nanos);
  final BigInteger s2 = s.multiply(s);

  Timer t = newTimer("foo");
  t.record(seconds, TimeUnit.SECONDS);
  clock.setWallTime(61000L);

  final double v = Utils.first(t.measure(), Statistic.totalOfSquares).value();

  final double factor = 1e9 * 1e9;
  final BigInteger perSec = s2.divide(BigInteger.valueOf(60));
  Assert.assertEquals(perSec.doubleValue() / factor, v, 1e-12);
}

开发者ID:Netflix，项目名称:spectator，代码行数:18，代码来源:ServoTimerTest.java

示例9: totalOfSquaresManySmallValues

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void totalOfSquaresManySmallValues() {
  Timer t = newTimer("foo");
  BigInteger sumOfSq = new BigInteger("0");
  for (int i = 0; i < 100000; ++i) {
    final long nanos = i;
    final BigInteger s = new BigInteger("" + nanos);
    final BigInteger s2 = s.multiply(s);
    sumOfSq = sumOfSq.add(s2);
    t.record(i, TimeUnit.NANOSECONDS);
  }
  clock.setWallTime(61000L);

  final double v = Utils.first(t.measure(), Statistic.totalOfSquares).value();

  final double factor = 1e9 * 1e9;
  sumOfSq = sumOfSq.divide(BigInteger.valueOf(60));
  Assert.assertEquals(sumOfSq.doubleValue() / factor, v, 1e-12);
}

开发者ID:Netflix，项目名称:spectator，代码行数:20，代码来源:ServoTimerTest.java

示例10: totalOfSquaresManyBigValues

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void totalOfSquaresManyBigValues() {
  Timer t = newTimer("foo");
  BigInteger sumOfSq = new BigInteger("0");
  for (int i = 0; i < 100000; ++i) {
    final long nanos = TimeUnit.SECONDS.toNanos(i);
    final BigInteger s = new BigInteger("" + nanos);
    final BigInteger s2 = s.multiply(s);
    sumOfSq = sumOfSq.add(s2);
    t.record(i, TimeUnit.SECONDS);
  }
  clock.setWallTime(61000L);

  final double v = Utils.first(t.measure(), Statistic.totalOfSquares).value();

  // Expected :3.3332833335E14
  // Actual   :3.3332833334999825E14
  final double factor = 1e9 * 1e9;
  sumOfSq = sumOfSq.divide(BigInteger.valueOf(60));
  Assert.assertEquals(sumOfSq.doubleValue() / factor, v, 2.0);
}

开发者ID:Netflix，项目名称:spectator，代码行数:22，代码来源:ServoTimerTest.java

示例11: expiration

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void expiration() {
  final long initTime = TimeUnit.MINUTES.toMillis(30);
  final long fifteenMinutes = TimeUnit.MINUTES.toMillis(15);

  // Expired on init, wait for activity to mark as active
  clock.setWallTime(initTime);
  Timer t = newTimer("foo");
  Assert.assertTrue(t.hasExpired());
  t.record(1, TimeUnit.SECONDS);
  Assert.assertFalse(t.hasExpired());

  // Expires with inactivity
  clock.setWallTime(initTime + fifteenMinutes + 1);
  Assert.assertTrue(t.hasExpired());

  // Activity brings it back
  t.record(42, TimeUnit.SECONDS);
  Assert.assertFalse(t.hasExpired());
}

开发者ID:Netflix，项目名称:spectator，代码行数:21，代码来源:ServoTimerTest.java

示例12: getTimer

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
public static Timer getTimer(String className, String name, String... additionalTags) {
	Map<String, String> tags = toMap(className, additionalTags);
	tags.put("unit", TimeUnit.SECONDS.name());
	return timers.computeIfAbsent(name, s -> new ConcurrentHashMap<>()).computeIfAbsent(tags, t -> {
		Id id = registry.createId(name, tags);
		return PercentileTimer.get(registry, id);
	});
}

开发者ID:Netflix，项目名称:conductor，代码行数:9，代码来源:Monitors.java

示例13: start

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
private static Stopwatch start(Timer sm) {

		Stopwatch sw = new BasicStopwatch() {

			@Override
			public void stop() {
				super.stop();
				long duration = getDuration(TimeUnit.MILLISECONDS);
				sm.record(duration, TimeUnit.MILLISECONDS);
			}

		};
		sw.start();
		return sw;
	}

开发者ID:Netflix，项目名称:conductor，代码行数:16，代码来源:Monitors.java

示例14: recordTime

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
void recordTime(final SNSMessage<?> message, final String timeName) {
    final Timer timer = this.registry.timer(
        timeName,
        Metrics.TagEventsType.getMetricName(),
        message.getClass().getName()
    );
    timer.record(this.registry.clock().wallTime() - message.getTimestamp(), TimeUnit.MILLISECONDS);
}

开发者ID:Netflix，项目名称:metacat，代码行数:9，代码来源:SNSNotificationMetric.java

示例15: metricsAreSentToAtlasPeriodically

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void metricsAreSentToAtlasPeriodically() throws InterruptedException {
	Timer t = registry.timer("t");

	for (int i = 0; i < 1000; i++)
		t.record(100, TimeUnit.MILLISECONDS);
	Thread.sleep(1500);

	Mockito.verify(exporter, Mockito.atLeastOnce()).export();
}

开发者ID:netflix-spring-one，项目名称:spring-cloud-netflix-contrib，代码行数:11，代码来源:AtlasAutoConfigurationIntegrationTests.java

示例16: record

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
private static void record(Timer t) throws Exception {
  long startingCount = t.count();
  long startingTime = t.totalTime();

  t.record(42, TimeUnit.MICROSECONDS);
  t.record(42, TimeUnit.HOURS);
  t.record(Integer.valueOf(42), TimeUnit.SECONDS);
  t.record(Long.valueOf(42), TimeUnit.SECONDS);

  t.record(new Runnable() {
    @Override public void run() {
    }
  });

  final String v = t.record(new Callable<String>() {
    @Override public String call() throws Exception {
      return "foo";
    }
  });
  assert "foo".equals(v);

  t.record(Main::methodToTime);
  assert "bar".equals(t.record(Main::getBar));

  assert t.count() == startingCount + 8;
  assert t.totalTime() == startingTime + 151284000042000L;
}

开发者ID:brharrington，项目名称:spectator-examples，代码行数:28，代码来源:Main.java

示例17: meterIsTimer

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
/**
 * Determine if meter is a Timer or not.
 */
public boolean meterIsTimer(Registry registry, Meter meter) {
  return idToTimer.computeIfAbsent(meter.id(), k -> {
      try {
        return registry.timers().anyMatch(m -> m.id().equals(meter.id()));
      } catch (ArrayIndexOutOfBoundsException aoex) {
        // !!! 20160929
        // !!! I dont know if this is a bug or what
        // !!! but the tests all get an array out of bounds calling stream()
        return meter instanceof Timer;
      }
      });
}

开发者ID:spinnaker，项目名称:kork，代码行数:16，代码来源:MetricDescriptorCache.java

示例18: writeRegistryWithTimer

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void writeRegistryWithTimer() throws IOException {
  DefaultRegistry testRegistry = new DefaultRegistry(clock);   
  Timer timer = testRegistry.timer(idAXY);
  timer.record(123, TimeUnit.MILLISECONDS);

  // If we get the expected result then we matched the expected descriptors,
  // which means the transforms occurred as expected.
  List<TimeSeries> tsList = writer.registryToTimeSeries(testRegistry);
  Assert.assertEquals(2, tsList.size());
}

开发者ID:spinnaker，项目名称:kork，代码行数:12，代码来源:StackdriverWriterTest.java

示例19: testInit

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testInit() {
  Timer timer = new DefaultPlaceholderTimer(new DefaultPlaceholderId("testInit", registry), registry);

  Assert.assertEquals(0L, timer.count());
  Assert.assertEquals(0L, timer.totalTime());
}

开发者ID:Netflix，项目名称:spectator，代码行数:8，代码来源:DefaultPlaceholderTimerTest.java

示例20: testRecordNegative

import com.netflix.spectator.api.Timer; //导入依赖的package包/类
@Test
public void testRecordNegative() {
  Timer timer = factory.timer(factory.createId("testRecordNegative"));
  timer.record(-42, TimeUnit.MILLISECONDS);
  Assert.assertEquals(timer.count(), 0L);
  Assert.assertEquals(0L, timer.totalTime());
}

开发者ID:Netflix，项目名称:spectator，代码行数:8，代码来源:DefaultPlaceholderTimerTest.java

注：本文中的com.netflix.spectator.api.Timer类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java RestClientException类代码示例发布时间：2022-05-23

Java ILineScatterCandleRadarDataSet类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18010|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9587|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8136|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8520|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8424|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9323|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8387|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7820|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8375|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7369|2022-11-06

客服电话

电子邮件

Java Timer类代码示例

示例1: processGcEvent

示例2: testRecord

示例3: testRecordCallableException

示例4: testRecordRunnableException

示例5: testMeasure

示例6: testRecordCallableException

示例7: testRecordRunnableException

示例8: totalOfSquaresOverflow

示例9: totalOfSquaresManySmallValues

示例10: totalOfSquaresManyBigValues

示例11: expiration

示例12: getTimer

示例13: start

示例14: recordTime

示例15: metricsAreSentToAtlasPeriodically

示例16: record

示例17: meterIsTimer

示例18: writeRegistryWithTimer

示例19: testInit

示例20: testRecordNegative

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

回调函数与Delphi的事件模型

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053