protected void dumpExecutors(ExecutorService service, PrintWriter out) throws IOException { if (service == null) { out.println("ExecutorService is not initialized"); return; } Map<String, ExecutorStatus> statuses = service.getAllExecutorStatuses(); for (ExecutorStatus status : statuses.values()) { status.dumpTo(out, " "); } }
private void checkStatusDump(ExecutorStatus status) throws IOException { StringWriter sw = new StringWriter(); status.dumpTo(sw, ""); String dump = sw.toString(); LOG.info("Got status dump:\n" + dump); assertTrue(dump.contains("Waiting on java.util.concurrent.atomic.AtomicBoolean")); }
protected void dumpExecutors(ExecutorService service, PrintWriter out) throws IOException { Map<String, ExecutorStatus> statuses = service.getAllExecutorStatuses(); for (ExecutorStatus status : statuses.values()) { status.dumpTo(out, " "); } }