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

Reduce garbage in AbstractUnsafe.flush0()

Browse Source
This commit is contained in:
Trustin Lee 2013-07-12 20:04:01 +09:00
parent 529d904d29
commit 6d1220b55e
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
transport/src/main/java/io/netty/channel/AbstractChannel.java
View File

@ -359,6 +359,13 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
*/
protected abstract class AbstractUnsafe implements Unsafe {
private final Runnable flushTask = new Runnable() {
@Override
public void run() {
flush0();
}
};
@Override
public final SocketAddress localAddress() {
return localAddress0();
@ -609,12 +616,7 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
} else {
if (!flushNowPending) {
flushNowPending = true;
eventLoop().execute(new Runnable() {
@Override
public void run() {
flush0();
}
});
eventLoop().execute(flushTask);
}
}
}