import org.apache.hadoop.hbase.monitoring.ThreadMonitoring; //导入依赖的package包/类
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
 

import org.apache.hadoop.hbase.monitoring.ThreadMonitoring; //导入依赖的package包/类
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}