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

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

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

ThreadMXBean.getThreadCount介绍

暂无

代码示例

代码示例来源:origin: mpusher/mpush

@Override
public int threadCount() {
  return threadMXBean.getThreadCount();
}

代码示例来源:origin: ltsopensource/light-task-scheduler

@Override
public int getThreadCount() {
  return threadMXBean.getThreadCount();
}

代码示例来源:origin: ltsopensource/light-task-scheduler

@Override
public int getThreadCount() {
  return threadMXBean.getThreadCount();
}

代码示例来源:origin: apache/ignite

@Override public int getThreadCount() {
  return threads.getThreadCount();
}

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

@Override
public int getThreadCount() {
  return underlying.getThreadCount();
}

代码示例来源:origin: aws/aws-sdk-java

@Override
public int getThreadCount() {
 ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
 return threadMXBean.getThreadCount();
}

代码示例来源:origin: kaaproject/kaa

@Override
 public int getLiveThreadCount() {
  return ManagementFactory.getThreadMXBean().getThreadCount();
 }
}

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

private int getThreadCount()
{
  return ManagementFactory.getThreadMXBean().getThreadCount();
}

代码示例来源:origin: btraceio/btrace

static long getThreadCount() {
  initThreadMBean();
  return threadMBean.getThreadCount();
}

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

@ManagedAttribute(description="Returns the number of live threads in the JVM")
public static int getNumThreads() {
  return ManagementFactory.getThreadMXBean().getThreadCount();
}

代码示例来源:origin: gocd/gocd

private Map<String, Object> getThreadCount(ThreadMXBean threadMXBean) {
  LinkedHashMap<String, Object> count = new LinkedHashMap<>();
  count.put("Current", threadMXBean.getThreadCount());
  count.put("Total", threadMXBean.getTotalStartedThreadCount());
  count.put("Daemon", threadMXBean.getDaemonThreadCount());
  count.put("Peak", threadMXBean.getPeakThreadCount());
  return count;
}

代码示例来源:origin: SonarSource/sonarqube

ProtobufSystemInfo.Section toProtobuf(MemoryMXBean memoryBean) {
 ProtobufSystemInfo.Section.Builder protobuf = ProtobufSystemInfo.Section.newBuilder();
 protobuf.setName(name);
 addAttributeInMb(protobuf,"Max Memory (MB)", Runtime.getRuntime().maxMemory());
 addAttributeInMb(protobuf, "Free Memory (MB)", Runtime.getRuntime().freeMemory());
 MemoryUsage heap = memoryBean.getHeapMemoryUsage();
 addAttributeInMb(protobuf, "Heap Committed (MB)", heap.getCommitted());
 addAttributeInMb(protobuf, "Heap Init (MB)", heap.getInit());
 addAttributeInMb(protobuf, "Heap Max (MB)", heap.getMax());
 addAttributeInMb(protobuf, "Heap Used (MB)", heap.getUsed());
 MemoryUsage nonHeap = memoryBean.getNonHeapMemoryUsage();
 addAttributeInMb(protobuf, "Non Heap Committed (MB)", nonHeap.getCommitted());
 addAttributeInMb(protobuf, "Non Heap Init (MB)", nonHeap.getInit());
 addAttributeInMb(protobuf, "Non Heap Max (MB)", nonHeap.getMax());
 addAttributeInMb(protobuf, "Non Heap Used (MB)", nonHeap.getUsed());
 OperatingSystemMXBean os = ManagementFactory.getOperatingSystemMXBean();
 setAttribute(protobuf,"System Load Average", format(Locale.ENGLISH, "%.1f%% (last minute)", os.getSystemLoadAverage() * 100.0));
 ThreadMXBean thread = ManagementFactory.getThreadMXBean();
 setAttribute(protobuf, "Threads", thread.getThreadCount());
 return protobuf.build();
}

代码示例来源:origin: LinShunKang/MyPerf4J

public JvmThreadMetrics(ThreadMXBean bean) {
  long threadIds[] = bean.getAllThreadIds();
  this.totalStarted = bean.getTotalStartedThreadCount();
  this.active = bean.getThreadCount();
  this.peak = bean.getPeakThreadCount();
  this.daemon = bean.getDaemonThreadCount();

代码示例来源:origin: pentaho/pentaho-kettle

private static void getSystemInfo( SlaveServerStatus serverStatus ) {
 OperatingSystemMXBean operatingSystemMXBean =
   java.lang.management.ManagementFactory.getOperatingSystemMXBean();
 ThreadMXBean threadMXBean = java.lang.management.ManagementFactory.getThreadMXBean();
 RuntimeMXBean runtimeMXBean = java.lang.management.ManagementFactory.getRuntimeMXBean();
 int cores = Runtime.getRuntime().availableProcessors();
 long freeMemory = Runtime.getRuntime().freeMemory();
 long totalMemory = Runtime.getRuntime().totalMemory();
 String osArch = operatingSystemMXBean.getArch();
 String osName = operatingSystemMXBean.getName();
 String osVersion = operatingSystemMXBean.getVersion();
 double loadAvg = operatingSystemMXBean.getSystemLoadAverage();
 int threadCount = threadMXBean.getThreadCount();
 long allThreadsCpuTime = 0L;
 long[] threadIds = threadMXBean.getAllThreadIds();
 for ( int i = 0; i < threadIds.length; i++ ) {
  allThreadsCpuTime += threadMXBean.getThreadCpuTime( threadIds[i] );
 }
 long uptime = runtimeMXBean.getUptime();
 serverStatus.setCpuCores( cores );
 serverStatus.setCpuProcessTime( allThreadsCpuTime );
 serverStatus.setUptime( uptime );
 serverStatus.setThreadCount( threadCount );
 serverStatus.setLoadAvg( loadAvg );
 serverStatus.setOsName( osName );
 serverStatus.setOsVersion( osVersion );
 serverStatus.setOsArchitecture( osArch );
 serverStatus.setMemoryFree( freeMemory );
 serverStatus.setMemoryTotal( totalMemory );
}

代码示例来源:origin: pentaho/pentaho-kettle

public ServerStatus() {
 OperatingSystemMXBean operatingSystemMXBean =
  java.lang.management.ManagementFactory.getOperatingSystemMXBean();
 ThreadMXBean threadMXBean = java.lang.management.ManagementFactory.getThreadMXBean();
 RuntimeMXBean runtimeMXBean = java.lang.management.ManagementFactory.getRuntimeMXBean();
 int cores = Runtime.getRuntime().availableProcessors();
 long freeMemory = Runtime.getRuntime().freeMemory();
 long totalMemory = Runtime.getRuntime().totalMemory();
 String osArch = operatingSystemMXBean.getArch();
 String osName = operatingSystemMXBean.getName();
 String osVersion = operatingSystemMXBean.getVersion();
 double loadAvg = operatingSystemMXBean.getSystemLoadAverage();
 int threadCount = threadMXBean.getThreadCount();
 long allThreadsCpuTime = 0L;
 long[] threadIds = threadMXBean.getAllThreadIds();
 for ( int i = 0; i < threadIds.length; i++ ) {
  allThreadsCpuTime += threadMXBean.getThreadCpuTime( threadIds[i] );
 }
 long uptime = runtimeMXBean.getUptime();
 setCpuCores( cores );
 setCpuProcessTime( allThreadsCpuTime );
 setUptime( uptime );
 setThreadCount( threadCount );
 setLoadAvg( loadAvg );
 setOsName( osName );
 setOsVersion( osVersion );
 setOsArchitecture( osArch );
 setMemoryFree( freeMemory );
 setMemoryTotal( totalMemory );
}

代码示例来源:origin: rapidoid/rapidoid

@Override
public void run() {
  Runtime rt = Runtime.getRuntime();
  long totalMem = rt.totalMemory();
  long maxMem = rt.maxMemory();
  long freeMem = rt.freeMemory();
  long usedMem = totalMem - freeMem;
  double megs = 1024.0 * 1024;
  MEM_TOTAL.put(U.time(), totalMem / megs);
  MEM_USED.put(U.time(), usedMem / megs);
  if (sysCpuM != null) {
    SYSTEM_CPU.put(U.time(), ((Number) Cls.invoke(sysCpuM, os)).doubleValue());
  }
  if (procCpuM != null) {
    PROCESS_CPU.put(U.time(), ((Number) Cls.invoke(procCpuM, os)).doubleValue());
  }
  if (openFileDescriptorCount != null) {
    NUM_FILE_DESC.put(U.time(), ((Number) Cls.invoke(openFileDescriptorCount, os)).doubleValue());
  }
  NUM_THREADS.put(U.time(), threads.getThreadCount());
}

代码示例来源:origin: patric-r/jvmtop

/**
 * calculates internal delta metrics
 * @throws Exception
 */
private void updateInternal() throws Exception
{
 long uptime = runtimeMXBean.getUptime();
 long cpuTime = proxyClient.getProcessCpuTime();
 //long cpuTime = osBean.getProcessCpuTime();
 long gcTime = sumGCTimes();
 gcCount = sumGCCount();
 if (lastUpTime > 0 && lastCPUTime > 0 && gcTime > 0)
 {
  deltaUptime_ = uptime - lastUpTime;
  deltaCpuTime_ = (cpuTime - lastCPUTime) / 1000000;
  deltaGcTime_ = gcTime - lastGcTime;
  gcLoad = calcLoad(deltaCpuTime_, deltaGcTime_);
  cpuLoad = calcLoad(deltaUptime_, deltaCpuTime_);
 }
 lastUpTime = uptime;
 lastCPUTime = cpuTime;
 lastGcTime = gcTime;
 totalLoadedClassCount_ = classLoadingMXBean_.getTotalLoadedClassCount();
 threadCount_ = threadMXBean.getThreadCount();
}

代码示例来源:origin: oldmanpushcart/greys-anatomy

private String drawThreadTable() {
  final TKv view = createKVView();
  view
      .add("COUNT", threadMXBean.getThreadCount())
      .add("DAEMON-COUNT", threadMXBean.getDaemonThreadCount())
      .add("LIVE-COUNT", threadMXBean.getPeakThreadCount())
      .add("STARTED-COUNT", threadMXBean.getTotalStartedThreadCount())
  ;
  return view.rendering();
}

代码示例来源: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: javamelody/javamelody

jvmArguments = buildJvmArguments();
final ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();
threadCount = threadBean.getThreadCount();
peakThreadCount = threadBean.getPeakThreadCount();
totalStartedThreadCount = threadBean.getTotalStartedThreadCount();

相关文章

微信公众号

最新文章

更多