Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use ThreadPool for stopping services 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638238 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-03-18 06:45:25 +00:00
parent 44e6f7d0cd
commit e41be74339
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java
View File

@ -18,6 +18,10 @@ package org.apache.activemq.transport.discovery.simple;
import java.io.IOException; import java.io.IOException;
import java.net.URI; import java.net.URI;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.activemq.command.DiscoveryEvent; import org.apache.activemq.command.DiscoveryEvent;
@ -35,7 +39,7 @@ import org.apache.commons.logging.LogFactory;
public class SimpleDiscoveryAgent implements DiscoveryAgent { public class SimpleDiscoveryAgent implements DiscoveryAgent {
private final static Log LOG = LogFactory.getLog(SimpleDiscoveryAgent.class); private final static Log LOG = LogFactory.getLog(SimpleDiscoveryAgent.class);
private static final ThreadPoolExecutor ASYNC_TASKS;
private long initialReconnectDelay = 1000; private long initialReconnectDelay = 1000;
private long maxReconnectDelay = 1000 * 30; private long maxReconnectDelay = 1000 * 30;
private long backOffMultiplier = 2; private long backOffMultiplier = 2;
@ -106,7 +110,7 @@ public class SimpleDiscoveryAgent implements DiscoveryAgent {
if (event.failed.compareAndSet(false, true)) { if (event.failed.compareAndSet(false, true)) {
listener.onServiceRemove(event); listener.onServiceRemove(event);
Thread thread = new Thread() { ASYNC_TASKS.execute(new Runnable() {
public void run() { public void run() {
// We detect a failed connection attempt because the service // We detect a failed connection attempt because the service
@ -160,9 +164,7 @@ public class SimpleDiscoveryAgent implements DiscoveryAgent {
listener.onServiceAdd(event); listener.onServiceAdd(event);
} }
}; });
thread.setDaemon(true);
thread.start();
} }
} }
@ -214,4 +216,15 @@ public class SimpleDiscoveryAgent implements DiscoveryAgent {
this.useExponentialBackOff = useExponentialBackOff; this.useExponentialBackOff = useExponentialBackOff;
} }
static {
ASYNC_TASKS = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 30, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), new ThreadFactory() {
public Thread newThread(Runnable runnable) {
Thread thread = new Thread(runnable, "Simple Discovery Agent: "+runnable);
thread.setDaemon(true);
return thread;
}
});
}
} }