Skip to content

Commit

Permalink
ISPN-5602 Create timeout scheduler executor
Browse files Browse the repository at this point in the history
  • Loading branch information
@pruivo @tristantarrant
pruivo authored and tristantarrant committed Jul 15, 2015
1 parent c30d565 commit c67c771
Show file tree
Hide file tree
Showing 4 changed files with 74 additions and 54 deletions.
57 changes: 31 additions & 26 deletions core/src/main/java/org/infinispan/factories/KnownComponentNames.java
View file
Expand Up @@ -2,6 +2,7 @@


import java.util.Arrays; import java.util.Arrays;
import java.util.Collection; import java.util.Collection;
import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;


Expand All @@ -28,30 +29,33 @@ public class KnownComponentNames {
public static final String STATE_TRANSFER_EXECUTOR = "org.infinispan.executors.stateTransferExecutor"; public static final String STATE_TRANSFER_EXECUTOR = "org.infinispan.executors.stateTransferExecutor";
public static final String TRANSACTION_VERSION_GENERATOR = "org.infinispan.transaction.versionGenerator"; public static final String TRANSACTION_VERSION_GENERATOR = "org.infinispan.transaction.versionGenerator";
public static final String ASYNC_OPERATIONS_EXECUTOR = "org.infinispan.executors.async"; public static final String ASYNC_OPERATIONS_EXECUTOR = "org.infinispan.executors.async";
public static final String TIMEOUT_SCHEDULE_EXECUTOR = "org.infinispan.executors.timeout";


// Please make sure this is kept up to date // Please make sure this is kept up to date
public static final Collection<String> ALL_KNOWN_COMPONENT_NAMES = Arrays.asList( public static final Collection<String> ALL_KNOWN_COMPONENT_NAMES = Arrays.asList(
ASYNC_TRANSPORT_EXECUTOR, ASYNC_NOTIFICATION_EXECUTOR, PERSISTENCE_EXECUTOR, ASYNC_OPERATIONS_EXECUTOR, EXPIRATION_SCHEDULED_EXECUTOR, ASYNC_REPLICATION_QUEUE_EXECUTOR, ASYNC_TRANSPORT_EXECUTOR, ASYNC_NOTIFICATION_EXECUTOR, PERSISTENCE_EXECUTOR, ASYNC_OPERATIONS_EXECUTOR,
EXPIRATION_SCHEDULED_EXECUTOR, ASYNC_REPLICATION_QUEUE_EXECUTOR,
MODULE_COMMAND_INITIALIZERS, MODULE_COMMAND_FACTORIES, GLOBAL_MARSHALLER, CACHE_MARSHALLER, CLASS_LOADER, MODULE_COMMAND_INITIALIZERS, MODULE_COMMAND_FACTORIES, GLOBAL_MARSHALLER, CACHE_MARSHALLER, CLASS_LOADER,
REMOTE_COMMAND_EXECUTOR, TOTAL_ORDER_EXECUTOR, STATE_TRANSFER_EXECUTOR, TRANSACTION_VERSION_GENERATOR REMOTE_COMMAND_EXECUTOR, TOTAL_ORDER_EXECUTOR, STATE_TRANSFER_EXECUTOR, TRANSACTION_VERSION_GENERATOR,
TIMEOUT_SCHEDULE_EXECUTOR
); );


public static final Collection<String> PER_CACHE_COMPONENT_NAMES = Arrays.asList(CACHE_MARSHALLER); public static final Collection<String> PER_CACHE_COMPONENT_NAMES = Collections.singletonList(CACHE_MARSHALLER);


private static final Map<String, Integer> DEFAULT_THREADCOUNTS = new HashMap<String, Integer>(4); private static final Map<String, Integer> DEFAULT_THREAD_COUNT = new HashMap<>(4);
private static final Map<String, Integer> DEFAULT_QUEUE_SIZE = new HashMap<String, Integer>(4); private static final Map<String, Integer> DEFAULT_QUEUE_SIZE = new HashMap<>(4);
private static final Map<String, Integer> DEFAULT_THREADPRIO = new HashMap<String, Integer>(6); private static final Map<String, Integer> DEFAULT_THREAD_PRIORITY = new HashMap<>(6);


static { static {
DEFAULT_THREADCOUNTS.put(ASYNC_NOTIFICATION_EXECUTOR, 1); DEFAULT_THREAD_COUNT.put(ASYNC_NOTIFICATION_EXECUTOR, 1);
DEFAULT_THREADCOUNTS.put(ASYNC_TRANSPORT_EXECUTOR, 25); DEFAULT_THREAD_COUNT.put(ASYNC_TRANSPORT_EXECUTOR, 25);
DEFAULT_THREADCOUNTS.put(ASYNC_REPLICATION_QUEUE_EXECUTOR, 1); DEFAULT_THREAD_COUNT.put(ASYNC_REPLICATION_QUEUE_EXECUTOR, 1);
DEFAULT_THREADCOUNTS.put(EXPIRATION_SCHEDULED_EXECUTOR, 1); DEFAULT_THREAD_COUNT.put(EXPIRATION_SCHEDULED_EXECUTOR, 1);
DEFAULT_THREADCOUNTS.put(PERSISTENCE_EXECUTOR, 4); DEFAULT_THREAD_COUNT.put(PERSISTENCE_EXECUTOR, 4);
DEFAULT_THREADCOUNTS.put(REMOTE_COMMAND_EXECUTOR, 200); DEFAULT_THREAD_COUNT.put(REMOTE_COMMAND_EXECUTOR, 200);
DEFAULT_THREADCOUNTS.put(TOTAL_ORDER_EXECUTOR, 32); DEFAULT_THREAD_COUNT.put(TOTAL_ORDER_EXECUTOR, 32);
DEFAULT_THREADCOUNTS.put(STATE_TRANSFER_EXECUTOR, 60); DEFAULT_THREAD_COUNT.put(STATE_TRANSFER_EXECUTOR, 60);
DEFAULT_THREADCOUNTS.put(ASYNC_OPERATIONS_EXECUTOR, 25); DEFAULT_THREAD_COUNT.put(ASYNC_OPERATIONS_EXECUTOR, 25);


DEFAULT_QUEUE_SIZE.put(ASYNC_NOTIFICATION_EXECUTOR, 100000); DEFAULT_QUEUE_SIZE.put(ASYNC_NOTIFICATION_EXECUTOR, 100000);
DEFAULT_QUEUE_SIZE.put(ASYNC_TRANSPORT_EXECUTOR, 100000); DEFAULT_QUEUE_SIZE.put(ASYNC_TRANSPORT_EXECUTOR, 100000);
Expand All @@ -63,23 +67,24 @@ public class KnownComponentNames {
DEFAULT_QUEUE_SIZE.put(STATE_TRANSFER_EXECUTOR, 0); DEFAULT_QUEUE_SIZE.put(STATE_TRANSFER_EXECUTOR, 0);
DEFAULT_QUEUE_SIZE.put(ASYNC_OPERATIONS_EXECUTOR, 1000); DEFAULT_QUEUE_SIZE.put(ASYNC_OPERATIONS_EXECUTOR, 1000);


DEFAULT_THREADPRIO.put(ASYNC_NOTIFICATION_EXECUTOR, Thread.MIN_PRIORITY); DEFAULT_THREAD_PRIORITY.put(ASYNC_NOTIFICATION_EXECUTOR, Thread.MIN_PRIORITY);
DEFAULT_THREADPRIO.put(ASYNC_REPLICATION_QUEUE_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(ASYNC_REPLICATION_QUEUE_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREADPRIO.put(ASYNC_TRANSPORT_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(ASYNC_TRANSPORT_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREADPRIO.put(EXPIRATION_SCHEDULED_EXECUTOR, Thread.MIN_PRIORITY); DEFAULT_THREAD_PRIORITY.put(EXPIRATION_SCHEDULED_EXECUTOR, Thread.MIN_PRIORITY);
DEFAULT_THREADPRIO.put(PERSISTENCE_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(PERSISTENCE_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREADPRIO.put(REMOTE_COMMAND_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(REMOTE_COMMAND_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREADPRIO.put(TOTAL_ORDER_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(TOTAL_ORDER_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREADPRIO.put(STATE_TRANSFER_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(STATE_TRANSFER_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREADPRIO.put(ASYNC_OPERATIONS_EXECUTOR, Thread.NORM_PRIORITY); DEFAULT_THREAD_PRIORITY.put(ASYNC_OPERATIONS_EXECUTOR, Thread.NORM_PRIORITY);
DEFAULT_THREAD_PRIORITY.put(TIMEOUT_SCHEDULE_EXECUTOR, Thread.NORM_PRIORITY);
} }


public static int getDefaultThreads(String componentName) { public static int getDefaultThreads(String componentName) {
return DEFAULT_THREADCOUNTS.get(componentName); return DEFAULT_THREAD_COUNT.get(componentName);
} }


public static int getDefaultThreadPrio(String componentName) { public static int getDefaultThreadPrio(String componentName) {
return DEFAULT_THREADPRIO.get(componentName); return DEFAULT_THREAD_PRIORITY.get(componentName);
} }


public static int getDefaultQueueSize(String componentName) { public static int getDefaultQueueSize(String componentName) {
Expand Down
40 changes: 26 additions & 14 deletions core/src/main/java/org/infinispan/factories/NamedExecutorsFactory.java
View file
Expand Up @@ -27,7 +27,9 @@
import static org.infinispan.factories.KnownComponentNames.PERSISTENCE_EXECUTOR; import static org.infinispan.factories.KnownComponentNames.PERSISTENCE_EXECUTOR;
import static org.infinispan.factories.KnownComponentNames.REMOTE_COMMAND_EXECUTOR; import static org.infinispan.factories.KnownComponentNames.REMOTE_COMMAND_EXECUTOR;
import static org.infinispan.factories.KnownComponentNames.STATE_TRANSFER_EXECUTOR; import static org.infinispan.factories.KnownComponentNames.STATE_TRANSFER_EXECUTOR;
import static org.infinispan.factories.KnownComponentNames.TIMEOUT_SCHEDULE_EXECUTOR;
import static org.infinispan.factories.KnownComponentNames.TOTAL_ORDER_EXECUTOR; import static org.infinispan.factories.KnownComponentNames.TOTAL_ORDER_EXECUTOR;
import static org.infinispan.factories.KnownComponentNames.getDefaultThreadPrio;
import static org.infinispan.factories.KnownComponentNames.shortened; import static org.infinispan.factories.KnownComponentNames.shortened;


/** /**
Expand All @@ -50,6 +52,7 @@ public class NamedExecutorsFactory extends NamedComponentFactory implements Auto
private BlockingTaskAwareExecutorService totalOrderExecutor; private BlockingTaskAwareExecutorService totalOrderExecutor;
private ExecutorService stateTransferExecutor; private ExecutorService stateTransferExecutor;
private ExecutorService asyncOperationsExecutor; private ExecutorService asyncOperationsExecutor;
private ScheduledExecutorService timeoutExecutor;


@Override @Override
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Expand All @@ -62,7 +65,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (notificationExecutor == null) { if (notificationExecutor == null) {
notificationExecutor = createExecutorService( notificationExecutor = createExecutorService(
globalConfiguration.listenerThreadPool(), globalConfiguration.listenerThreadPool(),
globalConfiguration, ASYNC_NOTIFICATION_EXECUTOR, ASYNC_NOTIFICATION_EXECUTOR,
ExecutorServiceType.DEFAULT); ExecutorServiceType.DEFAULT);
} }
} }
Expand All @@ -72,7 +75,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (persistenceExecutor == null) { if (persistenceExecutor == null) {
persistenceExecutor = createExecutorService( persistenceExecutor = createExecutorService(
globalConfiguration.persistenceThreadPool(), globalConfiguration.persistenceThreadPool(),
globalConfiguration, PERSISTENCE_EXECUTOR, PERSISTENCE_EXECUTOR,
ExecutorServiceType.DEFAULT); ExecutorServiceType.DEFAULT);
} }
} }
Expand All @@ -82,7 +85,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (asyncTransportExecutor == null) { if (asyncTransportExecutor == null) {
asyncTransportExecutor = createExecutorService( asyncTransportExecutor = createExecutorService(
globalConfiguration.transport().transportThreadPool(), globalConfiguration.transport().transportThreadPool(),
globalConfiguration, ASYNC_TRANSPORT_EXECUTOR, ASYNC_TRANSPORT_EXECUTOR,
ExecutorServiceType.DEFAULT); ExecutorServiceType.DEFAULT);
} }
} }
Expand All @@ -92,7 +95,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (expirationExecutor == null) { if (expirationExecutor == null) {
expirationExecutor = createExecutorService( expirationExecutor = createExecutorService(
globalConfiguration.evictionThreadPool(), globalConfiguration.evictionThreadPool(),
globalConfiguration, EXPIRATION_SCHEDULED_EXECUTOR, EXPIRATION_SCHEDULED_EXECUTOR,
ExecutorServiceType.SCHEDULED); ExecutorServiceType.SCHEDULED);
} }
} }
Expand All @@ -102,7 +105,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (asyncReplicationExecutor == null) { if (asyncReplicationExecutor == null) {
asyncReplicationExecutor = createExecutorService( asyncReplicationExecutor = createExecutorService(
globalConfiguration.replicationQueueThreadPool(), globalConfiguration.replicationQueueThreadPool(),
globalConfiguration, ASYNC_REPLICATION_QUEUE_EXECUTOR, ASYNC_REPLICATION_QUEUE_EXECUTOR,
ExecutorServiceType.SCHEDULED); ExecutorServiceType.SCHEDULED);
} }
} }
Expand All @@ -112,7 +115,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (remoteCommandsExecutor == null) { if (remoteCommandsExecutor == null) {
remoteCommandsExecutor = createExecutorService( remoteCommandsExecutor = createExecutorService(
globalConfiguration.transport().remoteCommandThreadPool(), globalConfiguration.transport().remoteCommandThreadPool(),
globalConfiguration, REMOTE_COMMAND_EXECUTOR, REMOTE_COMMAND_EXECUTOR,
ExecutorServiceType.BLOCKING); ExecutorServiceType.BLOCKING);
} }
} }
Expand All @@ -122,7 +125,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (totalOrderExecutor == null) { if (totalOrderExecutor == null) {
totalOrderExecutor = createExecutorService( totalOrderExecutor = createExecutorService(
globalConfiguration.transport().totalOrderThreadPool(), globalConfiguration.transport().totalOrderThreadPool(),
globalConfiguration, TOTAL_ORDER_EXECUTOR, TOTAL_ORDER_EXECUTOR,
ExecutorServiceType.BLOCKING); ExecutorServiceType.BLOCKING);
} }
} }
Expand All @@ -132,7 +135,7 @@ public <T> T construct(Class<T> componentType, String componentName) {
if (stateTransferExecutor == null) { if (stateTransferExecutor == null) {
stateTransferExecutor = createExecutorService( stateTransferExecutor = createExecutorService(
globalConfiguration.stateTransferThreadPool(), globalConfiguration.stateTransferThreadPool(),
globalConfiguration, STATE_TRANSFER_EXECUTOR, STATE_TRANSFER_EXECUTOR,
ExecutorServiceType.DEFAULT); ExecutorServiceType.DEFAULT);
} }
} }
Expand All @@ -141,11 +144,18 @@ public <T> T construct(Class<T> componentType, String componentName) {
synchronized (this) { synchronized (this) {
if (asyncOperationsExecutor == null) { if (asyncOperationsExecutor == null) {
asyncOperationsExecutor = createExecutorService( asyncOperationsExecutor = createExecutorService(
globalConfiguration.asyncThreadPool(), globalConfiguration, globalConfiguration.asyncThreadPool(),
ASYNC_OPERATIONS_EXECUTOR, ExecutorServiceType.DEFAULT); ASYNC_OPERATIONS_EXECUTOR, ExecutorServiceType.DEFAULT);
} }
} }
return (T) asyncOperationsExecutor; return (T) asyncOperationsExecutor;
} else if (componentName.endsWith(TIMEOUT_SCHEDULE_EXECUTOR)) {
synchronized (this) {
if (timeoutExecutor == null) {
timeoutExecutor = createExecutorService(null, TIMEOUT_SCHEDULE_EXECUTOR, ExecutorServiceType.SCHEDULED);
}
}
return (T) timeoutExecutor;
} else { } else {
throw new CacheConfigurationException("Unknown named executor " + componentName); throw new CacheConfigurationException("Unknown named executor " + componentName);
} }
Expand All @@ -166,21 +176,24 @@ public void stop() {
if (expirationExecutor != null) expirationExecutor.shutdownNow(); if (expirationExecutor != null) expirationExecutor.shutdownNow();
if (totalOrderExecutor != null) totalOrderExecutor.shutdownNow(); if (totalOrderExecutor != null) totalOrderExecutor.shutdownNow();
if (stateTransferExecutor != null) stateTransferExecutor.shutdownNow(); if (stateTransferExecutor != null) stateTransferExecutor.shutdownNow();
if (timeoutExecutor != null) timeoutExecutor.shutdownNow();
if (asyncOperationsExecutor != null) asyncOperationsExecutor.shutdownNow();
} }


@SuppressWarnings("unchecked")
private <T extends ExecutorService> T createExecutorService(ThreadPoolConfiguration threadPoolConfiguration, private <T extends ExecutorService> T createExecutorService(ThreadPoolConfiguration threadPoolConfiguration,
GlobalConfiguration globalCfg, String componentName, ExecutorServiceType type) { String componentName, ExecutorServiceType type) {
ThreadFactory threadFactory; ThreadFactory threadFactory;
ThreadPoolExecutorFactory executorFactory; ThreadPoolExecutorFactory executorFactory;
if (threadPoolConfiguration != null) { if (threadPoolConfiguration != null) {
threadFactory = threadPoolConfiguration.threadFactory() != null threadFactory = threadPoolConfiguration.threadFactory() != null
? threadPoolConfiguration.threadFactory() ? threadPoolConfiguration.threadFactory()
: createThreadFactoryWithDefaults(globalCfg, componentName); : createThreadFactoryWithDefaults(globalConfiguration, componentName);
executorFactory = threadPoolConfiguration.threadPoolFactory() != null executorFactory = threadPoolConfiguration.threadPoolFactory() != null
? threadPoolConfiguration.threadPoolFactory() ? threadPoolConfiguration.threadPoolFactory()
: createThreadPoolFactoryWithDefaults(componentName, type); : createThreadPoolFactoryWithDefaults(componentName, type);
} else { } else {
threadFactory = createThreadFactoryWithDefaults(globalCfg, componentName); threadFactory = createThreadFactoryWithDefaults(globalConfiguration, componentName);
executorFactory = createThreadPoolFactoryWithDefaults(componentName, type); executorFactory = createThreadPoolFactoryWithDefaults(componentName, type);
} }


Expand All @@ -197,8 +210,7 @@ private <T extends ExecutorService> T createExecutorService(ThreadPoolConfigurat


private ThreadFactory createThreadFactoryWithDefaults(GlobalConfiguration globalCfg, final String componentName) { private ThreadFactory createThreadFactoryWithDefaults(GlobalConfiguration globalCfg, final String componentName) {
// Use defaults // Use defaults
return new DefaultThreadFactory(null, return new DefaultThreadFactory(null, getDefaultThreadPrio(componentName), DefaultThreadFactory.DEFAULT_PATTERN,
KnownComponentNames.getDefaultThreadPrio(componentName), DefaultThreadFactory.DEFAULT_PATTERN,
globalCfg.transport().nodeName(), shortened(componentName)); globalCfg.transport().nodeName(), shortened(componentName));
} }


Expand Down
5 changes: 2 additions & 3 deletions core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
View file
Expand Up @@ -169,8 +169,7 @@ protected ScheduledExecutorService getTimeoutExecutor() {
public void initialize(@ComponentName(GLOBAL_MARSHALLER) StreamingMarshaller marshaller, public void initialize(@ComponentName(GLOBAL_MARSHALLER) StreamingMarshaller marshaller,
CacheManagerNotifier notifier, GlobalComponentRegistry gcr, CacheManagerNotifier notifier, GlobalComponentRegistry gcr,
TimeService timeService, InboundInvocationHandler globalHandler, TimeService timeService, InboundInvocationHandler globalHandler,
// TODO define a new scheduled executor for the replication timeouts @ComponentName(KnownComponentNames.TIMEOUT_SCHEDULE_EXECUTOR) ScheduledExecutorService timeoutExecutor) {
@ComponentName(KnownComponentNames.ASYNC_REPLICATION_QUEUE_EXECUTOR) ScheduledExecutorService timeoutExecutor) {
this.marshaller = marshaller; this.marshaller = marshaller;
this.notifier = notifier; this.notifier = notifier;
this.gcr = gcr; this.gcr = gcr;
Expand Down Expand Up @@ -389,7 +388,7 @@ private void buildChannel() {


if (channel == null && props.containsKey(CONFIGURATION_FILE)) { if (channel == null && props.containsKey(CONFIGURATION_FILE)) {
cfg = props.getProperty(CONFIGURATION_FILE); cfg = props.getProperty(CONFIGURATION_FILE);
Collection<URL> confs = null; Collection<URL> confs = Collections.emptyList();
try { try {
confs = fileLookup.lookupFileLocations(cfg, configuration.classLoader()); confs = fileLookup.lookupFileLocations(cfg, configuration.classLoader());
} catch (IOException io) { } catch (IOException io) {
Expand Down
26 changes: 15 additions & 11 deletions core/src/test/java/org/infinispan/test/fwk/UnitTestTestNGListener.java
View file
Expand Up @@ -167,27 +167,31 @@ public void onStart(ISuite isuite) {


@Override @Override
public void onFinish(ISuite isuite) { public void onFinish(ISuite isuite) {
if (log.isTraceEnabled()) { log.warn("Possible leaked threads at the end of the test suite:");
log.trace("Possible leaked threads at the end of the test suite:"); int count = 0;
for (Map.Entry<Thread, StackTraceElement[]> s : Thread.getAllStackTraces().entrySet()) { for (Map.Entry<Thread, StackTraceElement[]> s : Thread.getAllStackTraces().entrySet()) {
Thread thread = s.getKey(); Thread thread = s.getKey();
if (thread.getName().startsWith("testng-") if (thread.getName().startsWith("testng-")
|| seenThreads != null && seenThreads.contains(thread.getName() + "-" + thread.getId() + "-" + thread.hashCode())) { || seenThreads != null && seenThreads.contains(thread.getName() + "-" + thread.getId() + "-" + thread.hashCode())) {
continue; continue;
} }

count++;
if (log.isTraceEnabled()) {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
sb.append("Thread: name=").append(thread.getName()) sb.append("Thread: name=").append(thread.getName())
.append(", group=").append(thread.getThreadGroup() == null? null : thread.getThreadGroup().getName()) .append(", group=").append(thread.getThreadGroup() == null ? null : thread.getThreadGroup().getName())
.append(", isDaemon=").append(thread.isDaemon()) .append(", isDaemon=").append(thread.isDaemon())
.append(", isInterrupted=").append(thread.isInterrupted()) .append(", isInterrupted=").append(thread.isInterrupted())
.append(", Stack trace:\n"); .append(", Stack trace:\n");
for (StackTraceElement ste : s.getValue()) { for (StackTraceElement ste : s.getValue()) {
sb.append(" ").append(ste.toString()).append("\n"); sb.append(" ").append(ste.toString()).append("\n");
} }
log.trace(sb.toString()); log.trace(sb.toString());
} else {
log.warnf("Thread Name: %s", thread.getName());
} }
seenThreads = null;
} }
seenThreads = null;
log.warnf("Number of threads: %s", count);
} }
} }

0 comments on commit c67c771

Please sign in to comment.