java.lang.management.ThreadMXBean.resetPeakThreadCount()方法的使用及代码示例

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

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

ThreadMXBean.resetPeakThreadCount介绍

暂无

代码示例

代码示例来源:origin: org.scala-lang/scala-compiler

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

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

@Override
 public boolean doMonitor(ServiceEmitter emitter)
 {
  ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();

  final ServiceMetricEvent.Builder builder = builder();
  MonitorUtils.addDimensionsToBuilder(builder, dimensions);

  // Because between next two calls on ThreadMXBean new threads can be started we can observe some inconsistency
  // in counters values and finished counter could be even negative
  int newLiveThreads = threadBean.getThreadCount();
  long newStartedThreads = threadBean.getTotalStartedThreadCount();

  long startedThreadsDiff = newStartedThreads - lastStartedThreads;

  emitter.emit(builder.build("jvm/threads/started", startedThreadsDiff));
  emitter.emit(builder.build("jvm/threads/finished", lastLiveThreads + startedThreadsDiff - newLiveThreads));
  emitter.emit(builder.build("jvm/threads/live", newLiveThreads));
  emitter.emit(builder.build("jvm/threads/liveDaemon", threadBean.getDaemonThreadCount()));

  emitter.emit(builder.build("jvm/threads/livePeak", threadBean.getPeakThreadCount()));
  threadBean.resetPeakThreadCount();

  lastStartedThreads = newStartedThreads;
  lastLiveThreads = newLiveThreads;

  return true;
 }
}

代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

/**
 * Reset peak thread count in ThreadMXBean
 */
public static void resetPeakThreadCount() {
  threadMXBean.resetPeakThreadCount();
}

代码示例来源:origin: codefollower/Tomcat-Research

/**
 * Reset peak thread count in ThreadMXBean
 */
public static void resetPeakThreadCount() {
  threadMXBean.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.lamp/dotty-compiler_0.7

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.lamp/dotty-compiler_0.10

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.lamp/dotty-compiler_0.8

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.lamp/dotty-compiler_0.13

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.scala/scala-compiler

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: org.typelevel/scala-compiler

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.lamp/dotty-compiler_0.9

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: ch.epfl.lamp/dotty-compiler_0.12

@Override
public void resetPeakThreadCount() {
  underlying.resetPeakThreadCount();
}

代码示例来源:origin: org.avaje.metric/avaje-metric-core

@Override
 public long getValue() {
  // read and reset the peak
  int peakThreadCount = threadMXBean.getPeakThreadCount();
  threadMXBean.resetPeakThreadCount(); 
  return peakThreadCount;
 }
}

代码示例来源:origin: org.jboss.as/jboss-as-platform-mbean

@Override
public void execute(OperationContext context, ModelNode operation) throws OperationFailedException {
  try {
    ManagementFactory.getThreadMXBean().resetPeakThreadCount();
  } catch (SecurityException e) {
    throw new OperationFailedException(new ModelNode().set(e.toString()));
  }
  context.completeStep(OperationContext.RollbackHandler.NOOP_ROLLBACK_HANDLER);
}

代码示例来源:origin: org.wildfly.core/wildfly-platform-mbean

@Override
public void execute(OperationContext context, ModelNode operation) throws OperationFailedException {
  try {
    ManagementFactory.getThreadMXBean().resetPeakThreadCount();
  } catch (SecurityException e) {
    throw new OperationFailedException(e.toString());
  }
  context.completeStep(OperationContext.RollbackHandler.NOOP_ROLLBACK_HANDLER);
}

代码示例来源:origin: wildfly/wildfly-core

@Override
public void execute(OperationContext context, ModelNode operation) throws OperationFailedException {
  try {
    ManagementFactory.getThreadMXBean().resetPeakThreadCount();
  } catch (SecurityException e) {
    throw new OperationFailedException(e.toString());
  }
  context.completeStep(OperationContext.RollbackHandler.NOOP_ROLLBACK_HANDLER);
}

代码示例来源:origin: com.metamx/java-util

@Override
 public boolean doMonitor(ServiceEmitter emitter)
 {
  ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();

  final ServiceMetricEvent.Builder builder = builder();
  MonitorUtils.addDimensionsToBuilder(builder, dimensions);

  // Because between next two calls on ThreadMXBean new threads can be started we can observe some inconsistency
  // in counters values and finished counter could be even negative
  int newLiveThreads = threadBean.getThreadCount();
  long newStartedThreads = threadBean.getTotalStartedThreadCount();

  long startedThreadsDiff = newStartedThreads - lastStartedThreads;

  emitter.emit(builder.build("jvm/threads/started", startedThreadsDiff));
  emitter.emit(builder.build("jvm/threads/finished", lastLiveThreads + startedThreadsDiff - newLiveThreads));
  emitter.emit(builder.build("jvm/threads/live", newLiveThreads));
  emitter.emit(builder.build("jvm/threads/liveDaemon", threadBean.getDaemonThreadCount()));

  emitter.emit(builder.build("jvm/threads/livePeak", threadBean.getPeakThreadCount()));
  threadBean.resetPeakThreadCount();

  lastStartedThreads = newStartedThreads;
  lastLiveThreads = newLiveThreads;

  return true;
 }
}

代码示例来源:origin: org.apache.druid/java-util

@Override
 public boolean doMonitor(ServiceEmitter emitter)
 {
  ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();

  final ServiceMetricEvent.Builder builder = builder();
  MonitorUtils.addDimensionsToBuilder(builder, dimensions);

  // Because between next two calls on ThreadMXBean new threads can be started we can observe some inconsistency
  // in counters values and finished counter could be even negative
  int newLiveThreads = threadBean.getThreadCount();
  long newStartedThreads = threadBean.getTotalStartedThreadCount();

  long startedThreadsDiff = newStartedThreads - lastStartedThreads;

  emitter.emit(builder.build("jvm/threads/started", startedThreadsDiff));
  emitter.emit(builder.build("jvm/threads/finished", lastLiveThreads + startedThreadsDiff - newLiveThreads));
  emitter.emit(builder.build("jvm/threads/live", newLiveThreads));
  emitter.emit(builder.build("jvm/threads/liveDaemon", threadBean.getDaemonThreadCount()));

  emitter.emit(builder.build("jvm/threads/livePeak", threadBean.getPeakThreadCount()));
  threadBean.resetPeakThreadCount();

  lastStartedThreads = newStartedThreads;
  lastLiveThreads = newLiveThreads;

  return true;
 }
}

代码示例来源:origin: io.druid/java-util

@Override
 public boolean doMonitor(ServiceEmitter emitter)
 {
  ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();

  final ServiceMetricEvent.Builder builder = builder();
  MonitorUtils.addDimensionsToBuilder(builder, dimensions);

  // Because between next two calls on ThreadMXBean new threads can be started we can observe some inconsistency
  // in counters values and finished counter could be even negative
  int newLiveThreads = threadBean.getThreadCount();
  long newStartedThreads = threadBean.getTotalStartedThreadCount();

  long startedThreadsDiff = newStartedThreads - lastStartedThreads;

  emitter.emit(builder.build("jvm/threads/started", startedThreadsDiff));
  emitter.emit(builder.build("jvm/threads/finished", lastLiveThreads + startedThreadsDiff - newLiveThreads));
  emitter.emit(builder.build("jvm/threads/live", newLiveThreads));
  emitter.emit(builder.build("jvm/threads/liveDaemon", threadBean.getDaemonThreadCount()));

  emitter.emit(builder.build("jvm/threads/livePeak", threadBean.getPeakThreadCount()));
  threadBean.resetPeakThreadCount();

  lastStartedThreads = newStartedThreads;
  lastLiveThreads = newLiveThreads;

  return true;
 }
}

代码示例来源:origin: com.metamx/server-metrics

@Override
 public boolean doMonitor(ServiceEmitter emitter)
 {
  ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();

  final ServiceMetricEvent.Builder builder = builder();
  MonitorUtils.addDimensionsToBuilder(builder, dimensions);

  // Because between next two calls on ThreadMXBean new threads can be started we can observe some inconsistency
  // in counters values and finished counter could be even negative
  int newLiveThreads = threadBean.getThreadCount();
  long newStartedThreads = threadBean.getTotalStartedThreadCount();

  long startedThreadsDiff = newStartedThreads - lastStartedThreads;

  emitter.emit(builder.build("jvm/threads/started", startedThreadsDiff));
  emitter.emit(builder.build("jvm/threads/finished", lastLiveThreads + startedThreadsDiff - newLiveThreads));
  emitter.emit(builder.build("jvm/threads/live", newLiveThreads));
  emitter.emit(builder.build("jvm/threads/liveDaemon", threadBean.getDaemonThreadCount()));

  emitter.emit(builder.build("jvm/threads/livePeak", threadBean.getPeakThreadCount()));
  threadBean.resetPeakThreadCount();

  lastStartedThreads = newStartedThreads;
  lastLiveThreads = newLiveThreads;

  return true;
 }
}

相关文章

微信公众号

最新文章

更多