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

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

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

ThreadMXBean.setThreadContentionMonitoringEnabled介绍

暂无

代码示例

代码示例来源:origin: deeplearning4j/nd4j

public static void setContentionTracing(boolean val) {
  threadBean.setThreadContentionMonitoringEnabled(val);
}

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

@Override
public void setThreadContentionMonitoringEnabled(boolean enable) {
  underlying.setThreadContentionMonitoringEnabled(enable);
}

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

public static void setContentionTracing(boolean val) {
 threadBean.setThreadContentionMonitoringEnabled(val);
}

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

protected static String enable(int type, boolean flag) {
  ThreadMXBean bean=ManagementFactory.getThreadMXBean();
  boolean supported=false;
  if(type == 1) { // cpu
    supported=bean.isThreadCpuTimeSupported();
    if(supported)
      bean.setThreadCpuTimeEnabled(flag);
  }
  else if(type == 2) {
    supported=bean.isThreadContentionMonitoringSupported();
    if(supported)
      bean.setThreadContentionMonitoringEnabled(flag);
  }
  String tmp=type == 1? "CPU" : "contention";
  return String.format("%s monitoring supported: %b, %s monitoring enabled: %b", tmp, supported, tmp, supported && flag);
}

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

public void enableIfDiagnosticsModeIsEnabled() {
  if (systemEnvironment.get(SystemEnvironment.GO_DIAGNOSTICS_MODE)) {
    ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
    if (threadMXBean.isThreadContentionMonitoringSupported()) {
      threadMXBean.setThreadContentionMonitoringEnabled(true);
    }
    if (threadMXBean.isThreadCpuTimeSupported()) {
      threadMXBean.setThreadCpuTimeEnabled(true);
    }
    if (isThreadAllocatedMemorySupported(threadMXBean)) {
      setThreadAllocatedMemoryEnabled(threadMXBean);
    }
  }
}

代码示例来源:origin: Netflix/servo

bean.setThreadContentionMonitoringEnabled(true);

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

@Override
public void setThreadContentionMonitoringEnabled(boolean enable) {
  underlying.setThreadContentionMonitoringEnabled(enable);
}

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

@Override
public void setThreadContentionMonitoringEnabled(boolean enable) {
  underlying.setThreadContentionMonitoringEnabled(enable);
}

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

@Override
public void setThreadContentionMonitoringEnabled(boolean enable) {
  underlying.setThreadContentionMonitoringEnabled(enable);
}

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

@Override
public void setThreadContentionMonitoringEnabled(boolean enable) {
  underlying.setThreadContentionMonitoringEnabled(enable);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

public static void setContentionTracing(boolean val) {
 threadBean.setThreadContentionMonitoringEnabled(val);
}

代码示例来源:origin: org.nd4j/canova-api

public static void setContentionTracing(boolean val) {
  threadBean.setThreadContentionMonitoringEnabled(val);
}

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

ManagementFactory.getThreadMXBean().setThreadContentionMonitoringEnabled(true);

代码示例来源:origin: stackoverflow.com

ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
threadMXBean.setThreadContentionMonitoringEnabled(true);

//Then, use specific thread IDs to get contention info periodically:

int threadID = ... //you can use getId() on each thread you created
ThreadInfo info = threadMXBean.getThreadInfo(threadID);
info.getBlockedTime(); //returns millis
info.getWaitedTime(); //returns millis

代码示例来源:origin: worstcase/gumshoe

public void setContentionMonitoringEnabled(boolean enable) {
  final ThreadMXBean mbean = ManagementFactory.getThreadMXBean();
  if(enabled && ! mbean.isThreadContentionMonitoringSupported()) {
    throw new UnsupportedOperationException("JVM does not support contention monitoring");
  }
  mbean.setThreadContentionMonitoringEnabled(enable);
}

代码示例来源:origin: com.custardsource.parfait/parfait-core

public EventTimer(String prefix, MonitorableRegistry registry, ThreadMetricSuite metrics,
         boolean enableCpuCollection, boolean enableContentionCollection, List<StepMeasurementSink> stepMeasurementSinks) {
  this.metricSuite = metrics;
  this.prefix = prefix;
  this.registry = registry;
  if (enableCpuCollection) {
    ManagementFactory.getThreadMXBean().setThreadCpuTimeEnabled(true);
  }
  if (enableContentionCollection) {
    ManagementFactory.getThreadMXBean().setThreadContentionMonitoringEnabled(true);
  }
  this.stepMeasurementSinks = ImmutableList.copyOf(stepMeasurementSinks);
}

代码示例来源:origin: com.orbitz.erma/erma-lib

/**
 * Default constructor. Enables thread contention
 * monitoring.
 */
public DeadlockDetectionTimerTask() {
  super();
  final ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();
  if(threadBean.isThreadContentionMonitoringSupported()) {
    threadBean.setThreadContentionMonitoringEnabled(true);
  }
}

代码示例来源:origin: org.jppf/jppf-common-node

/**
 * Ensure that thread contention monitoring is enabled, if it is supported.
 */
private void checkThreadCapabilities()
{
 if (threadsMXBean.isThreadContentionMonitoringSupported() && !threadsMXBean.isThreadContentionMonitoringEnabled())
  threadsMXBean.setThreadContentionMonitoringEnabled(true);
}

代码示例来源:origin: org.jppf/jppf-common

/**
 * Ensure that thread contention monitoring is enabled, if it is supported.
 */
private static void checkThreadCapabilities() {
 if (threadsMXBean.isThreadContentionMonitoringSupported() && !threadsMXBean.isThreadContentionMonitoringEnabled())
  threadsMXBean.setThreadContentionMonitoringEnabled(true);
}

代码示例来源:origin: performancecopilot/parfait

@Override
public void run() {
  ManagementFactory.getThreadMXBean().setThreadContentionMonitoringEnabled(true);
  this.blockedMetricCollector = new BlockedMetricCollector();
  for (int i = 0; i < iterations; i++) {
    for (MonitoredCounter counter : counters) {
      counter.inc();
    }
  }
  blockedMetricCollector.computeFinalValues();
}

相关文章

微信公众号

最新文章

更多