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

Switching to sun.misc.Unsafe as an experiment, easily revertable

Browse source
This commit is contained in:
Viktor Klang 2011-11-21 17:49:21 +01:00
parent 8d356ba4a5
commit 4fdf698611
4 changed files with 59 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

21
akka-actor/src/main/java/akka/dispatch/AbstractMailbox.java
View file

@ -4,15 +4,18 @@
package akka.dispatch;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import akka.util.Unsafe;
abstract class AbstractMailbox {
private volatile int _status; // not initialized because this is faster: 0 == Open
protected final static AtomicIntegerFieldUpdater<AbstractMailbox> updater =
AtomicIntegerFieldUpdater.newUpdater(AbstractMailbox.class, "_status");
final class AbstractMailbox {
final static long mailboxStatusOffset;
final static long systemMessageOffset;
private volatile SystemMessage _systemQueue; // not initialized because this is faster
protected final static AtomicReferenceFieldUpdater<AbstractMailbox, SystemMessage> systemQueueUpdater =
AtomicReferenceFieldUpdater.newUpdater(AbstractMailbox.class, SystemMessage.class, "_systemQueue");
static {
try {
mailboxStatusOffset = Unsafe.instance.objectFieldOffset(Mailbox.class.getDeclaredField("_status"));
systemMessageOffset = Unsafe.instance.objectFieldOffset(Mailbox.class.getDeclaredField("_systemQueue"));
} catch(Throwable t){
throw new ExceptionInInitializerError(t);
}
}
}