import org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutorMBean; //导入依赖的package包/类
@Override
public void execute(NodeProbe probe)
{
    System.out.printf("%-25s%10s%10s%15s%10s%18s%n", "Pool Name", "Active", "Pending", "Completed", "Blocked", "All time blocked");

    Iterator<Map.Entry<String, JMXEnabledThreadPoolExecutorMBean>> threads = probe.getThreadPoolMBeanProxies();
    while (threads.hasNext())
    {
        Map.Entry<String, JMXEnabledThreadPoolExecutorMBean> thread = threads.next();
        String poolName = thread.getKey();
        JMXEnabledThreadPoolExecutorMBean threadPoolProxy = thread.getValue();
        System.out.printf("%-25s%10s%10s%15s%10s%18s%n",
                poolName,
                threadPoolProxy.getActiveCount(),
                threadPoolProxy.getPendingTasks(),
                threadPoolProxy.getCompletedTasks(),
                threadPoolProxy.getCurrentlyBlockedTasks(),
                threadPoolProxy.getTotalBlockedTasks());
    }

    System.out.printf("%n%-20s%10s%n", "Message type", "Dropped");
    for (Map.Entry<String, Integer> entry : probe.getDroppedMessages().entrySet())
        System.out.printf("%-20s%10s%n", entry.getKey(), entry.getValue());
}
 

import org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutorMBean; //导入依赖的package包/类
public void printThreadPoolStats(PrintStream outs)
{
    outs.printf("%-25s%10s%10s%15s%10s%18s%n", "Pool Name", "Active", "Pending", "Completed", "Blocked", "All time blocked");

    Iterator<Map.Entry<String, JMXEnabledThreadPoolExecutorMBean>> threads = probe.getThreadPoolMBeanProxies();
    while (threads.hasNext())
    {
        Entry<String, JMXEnabledThreadPoolExecutorMBean> thread = threads.next();
        String poolName = thread.getKey();
        JMXEnabledThreadPoolExecutorMBean threadPoolProxy = thread.getValue();
        outs.printf("%-25s%10s%10s%15s%10s%18s%n",
                    poolName,
                    threadPoolProxy.getActiveCount(),
                    threadPoolProxy.getPendingTasks(),
                    threadPoolProxy.getCompletedTasks(),
                    threadPoolProxy.getCurrentlyBlockedTasks(),
                    threadPoolProxy.getTotalBlockedTasks());
    }

    outs.printf("%n%-20s%10s%n", "Message type", "Dropped");
    for (Entry<String, Integer> entry : probe.getDroppedMessages().entrySet())
        outs.printf("%-20s%10s%n", entry.getKey(), entry.getValue());
}
 

import org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutorMBean; //导入依赖的package包/类
public Map.Entry<String, JMXEnabledThreadPoolExecutorMBean> next()
{
    ObjectName objectName = resIter.next();
    String poolName = objectName.getKeyProperty("type");
    JMXEnabledThreadPoolExecutorMBean threadPoolProxy = JMX.newMBeanProxy(mbeanServerConn, objectName, JMXEnabledThreadPoolExecutorMBean.class);
    return new AbstractMap.SimpleImmutableEntry<String, JMXEnabledThreadPoolExecutorMBean>(poolName, threadPoolProxy);
}