raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=act correct two comments in AbstractNodeQueue.java

Browse source
This commit is contained in:
Roland Kuhn 2015-10-01 11:14:54 +02:00
parent 28cdc790f9
commit 1830b729bb
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java
View file

@ -14,7 +14,8 @@ import java.util.concurrent.atomic.AtomicReference;
*/
@SuppressWarnings("serial")
public abstract class AbstractNodeQueue<T> extends AtomicReference<AbstractNodeQueue.Node<T>> {
// Extends AtomicReference for the "head" slot (which is the one that is appended to) since Unsafe does not expose XCHG operation intrinsically
// Extends AtomicReference for the "head" slot (which is the one that is appended to) since
// Unsafe does not expose XCHG operation intrinsically before JDK 8
@SuppressWarnings("unused")
private volatile Node<T> _tailDoNotCallMeDirectly;
@ -34,7 +35,7 @@ public abstract class AbstractNodeQueue<T> extends AtomicReference<AbstractNodeQ
final Node<T> tail = ((Node<T>)Unsafe.instance.getObjectVolatile(this, tailOffset));
Node<T> next = tail.next();
if (next == null && get() != tail) {
// if tail != head this is not going to change until consumer makes progress
// if tail != head this is not going to change until producer makes progress
// we can avoid reading the head and just spin on next until it shows up
do {
next = tail.next();