本文整理了Java中java.lang.management.ThreadMXBean.getThreadCount()
方法的一些代码示例,展示了ThreadMXBean.getThreadCount()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ThreadMXBean.getThreadCount()
方法的具体详情如下:
包路径:java.lang.management.ThreadMXBean
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!