andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed memory leak in OrderedMemoryAwareThreadPoolExecutor

Browse Source
This commit is contained in:
Trustin Lee 2009-04-23 00:46:41 +00:00
parent 967bd4d06d
commit 5cd9b6722a
1 changed files with 2 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/org/jboss/netty/handler/execution/OrderedMemoryAwareThreadPoolExecutor.java
View File

@ -30,10 +30,8 @@ import java.util.concurrent.TimeUnit;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelEvent;
import org.jboss.netty.channel.ChannelState;
import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.util.ObjectSizeEstimator;
import org.jboss.netty.util.internal.ConcurrentIdentityHashMap;
import org.jboss.netty.util.internal.ConcurrentIdentityWeakKeyHashMap;
/**
* A {@link MemoryAwareThreadPoolExecutor} which maintains the
@ -71,7 +69,7 @@ public class OrderedMemoryAwareThreadPoolExecutor extends
MemoryAwareThreadPoolExecutor {
private final ConcurrentMap<Channel, Executor> childExecutors =
new ConcurrentIdentityHashMap<Channel, Executor>();
new ConcurrentIdentityWeakKeyHashMap<Channel, Executor>();
/**
* Creates a new instance.
@ -169,15 +167,6 @@ public class OrderedMemoryAwareThreadPoolExecutor extends
executor = oldExecutor;
}
}
// Remove the entry when the channel closes.
if (e instanceof ChannelStateEvent) {
ChannelStateEvent se = (ChannelStateEvent) e;
if (se.getState() == ChannelState.OPEN &&
!channel.isOpen()) {
childExecutors.remove(channel);
}
}
return executor;
}