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

Refactoring that is likely to help JVM optimize QNode more aggressively

Browse Source
This commit is contained in:
Trustin Lee 2009-02-03 11:57:53 +00:00
parent 67d90615e1
commit 42afa85e53
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/org/jboss/netty/util/LinkedTransferQueue.java
View File

@ -158,9 +158,14 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E> implements Blocking
} }
boolean casNext(QNode cmp, QNode val) { boolean casNext(QNode cmp, QNode val) {
if (nextUpdater == null) { if (nextUpdater != null) {
// Safe mode. return nextUpdater.compareAndSet(this, cmp, val);
synchronized (this) { } else {
return alternativeCasNext(cmp, val);
}
}
private synchronized boolean alternativeCasNext(QNode cmp, QNode val) {
if (next == cmp) { if (next == cmp) {
next = val; next = val;
return true; return true;
@ -168,10 +173,6 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E> implements Blocking
return false; return false;
} }
} }
} else {
return nextUpdater.compareAndSet(this, cmp, val);
}
}
} }
/** /**