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

ARTEMIS-874: ThreadGroup memory leak

This commit is contained in:
dOkI 2017-05-05 22:10:59 +05:00 committed by Clebert Suconic
parent 4f22a56066
commit 18bc7e1a2e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ActiveMQThreadFactory.java
View File

@ -24,7 +24,7 @@ import java.util.concurrent.atomic.AtomicInteger;
public final class ActiveMQThreadFactory implements ThreadFactory { public final class ActiveMQThreadFactory implements ThreadFactory {
private final ThreadGroup group; private String groupName;
private final AtomicInteger threadCount = new AtomicInteger(0); private final AtomicInteger threadCount = new AtomicInteger(0);
@ -59,7 +59,7 @@ public final class ActiveMQThreadFactory implements ThreadFactory {
* @param tccl the context class loader of newly created threads * @param tccl the context class loader of newly created threads
*/ */
public ActiveMQThreadFactory(final String groupName, String prefix, final boolean daemon, final ClassLoader tccl) { public ActiveMQThreadFactory(final String groupName, String prefix, final boolean daemon, final ClassLoader tccl) {
group = new ThreadGroup(groupName + "-" + System.identityHashCode(this)); this.groupName = groupName;
this.prefix = prefix; this.prefix = prefix;
@ -97,7 +97,7 @@ public final class ActiveMQThreadFactory implements ThreadFactory {
} }
private Thread createThread(final Runnable command) { private Thread createThread(final Runnable command) {
final Thread t = new Thread(group, command, prefix + threadCount.getAndIncrement() + " (" + group.getName() + ")"); final Thread t = new Thread(command, prefix + threadCount.getAndIncrement() + " (" + groupName + ")");
t.setDaemon(daemon); t.setDaemon(daemon);
t.setPriority(threadPriority); t.setPriority(threadPriority);
t.setContextClassLoader(tccl); t.setContextClassLoader(tccl);